diff --git a/pipeline/assets/gtfs.py b/pipeline/assets/gtfs.py index 7861021..caa6f98 100644 --- 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 index 1690e63..6357ebc 100644 --- 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 index 285e43e..572979f 100644 --- 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 index 3b89e88..756893f 100644 --- 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: