Skip to content

Commit 53d8ff5

Browse files
Addressing ruff issues
1 parent be94f13 commit 53d8ff5

File tree

2 files changed

+222
-135
lines changed

2 files changed

+222
-135
lines changed

usaspending_api/etl/management/commands/archive_table_in_delta.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,10 @@ def handle(self, *args, **options) -> None:
120120
)
121121

122122
# Retrieve data from Postgres
123-
query_with_predicate = f"(SELECT * FROM {qualified_source_table} WHERE {archive_date_field} < '{archive_date_string}') AS tmp"
123+
query_with_predicate = (
124+
f"(SELECT * FROM {qualified_source_table} "
125+
f"WHERE {archive_date_field} < '{archive_date_string}') AS tmp"
126+
)
124127

125128
df = spark.read.jdbc(
126129
url=jdbc_url,

0 commit comments

Comments
 (0)