fix: linting

mobidata-bw · Feb 23, 2025 · 0ed0d95 · 0ed0d95
1 parent 79c6a8a
commit 0ed0d95
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 4 deletions.
diff --git a/pipeline/assets/gtfs.py b/pipeline/assets/gtfs.py
@@ -74,7 +74,9 @@ def reload_pgbouncer_databases(import_op):
 
 @graph_asset(
     group_name='gtfs',
-    automation_condition=(AutomationCondition.on_cron('0 1 * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()),
+    automation_condition=(
+        AutomationCondition.on_cron('0 1 * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()
+    ),
 )
 def gtfs():
     """

diff --git a/pipeline/assets/radvis.py b/pipeline/assets/radvis.py
@@ -23,7 +23,9 @@
 @asset(
     compute_kind='Geopackage',
     group_name='radvis',
-    automation_condition=(AutomationCondition.on_cron('0 1 * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()),
+    automation_condition=(
+        AutomationCondition.on_cron('0 1 * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()
+    ),
 )
 def radnetz_bw_download() -> None:
     """

diff --git a/pipeline/assets/sharing.py b/pipeline/assets/sharing.py
@@ -22,7 +22,9 @@
     io_manager_key='pg_gpd_io_manager',
     compute_kind='Lamassu',
     group_name='sharing',
-    automation_condition=(AutomationCondition.on_cron('0 * * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()),
+    automation_condition=(
+        AutomationCondition.on_cron('0 * * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()
+    ),
 )
 def sharing_stations(context, lamassu: LamassuResource) -> pd.DataFrame:
     """

diff --git a/pipeline/assets/traffic_incidents.py b/pipeline/assets/traffic_incidents.py
@@ -25,7 +25,9 @@
 @asset(
     compute_kind='DATEX2',
     group_name='traffic',
-    automation_condition=(AutomationCondition.on_cron('0/5 * * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()),
+    automation_condition=(
+        AutomationCondition.on_cron('0/5 * * * *') & ~AutomationCondition.in_progress() | AutomationCondition.eager()
+    ),
     key_prefix=ROADWORKS_ASSET_KEY_PREFIX,
 )
 def roadworks_svzbw_datex2() -> None: