diff --git a/warehouse/oso_dagster/assets/eas_optimism.py b/warehouse/oso_dagster/assets/eas_optimism.py index 72f81095b..e7e22ce08 100644 --- a/warehouse/oso_dagster/assets/eas_optimism.py +++ b/warehouse/oso_dagster/assets/eas_optimism.py @@ -208,7 +208,6 @@ def get_optimism_eas(context: AssetExecutionContext, client: Client): key_prefix="ethereum_attestation_service_optimism", partitions_def=WeeklyPartitionsDefinition( start_date=EAS_OPTIMISM_FIRST_ATTESTATION.isoformat().split("T", maxsplit=1)[0], - end_date=(datetime.now()).isoformat().split("T", maxsplit=1)[0], ), op_tags={ "dagster-k8s/config": K8S_CONFIG, diff --git a/warehouse/oso_dagster/assets/open_collective.py b/warehouse/oso_dagster/assets/open_collective.py index 76b7dbdb2..e379b0cf8 100644 --- a/warehouse/oso_dagster/assets/open_collective.py +++ b/warehouse/oso_dagster/assets/open_collective.py @@ -592,7 +592,6 @@ def base_open_collective_client(personal_token: str): key_prefix="open_collective", partitions_def=WeeklyPartitionsDefinition( start_date=OPEN_COLLECTIVE_TX_EPOCH.split("T", maxsplit=1)[0], - end_date=(datetime.now()).isoformat().split("T")[0], ), op_tags={ "dagster-k8s/config": K8S_CONFIG, @@ -637,7 +636,6 @@ def expenses( key_prefix="open_collective", partitions_def=WeeklyPartitionsDefinition( start_date=OPEN_COLLECTIVE_TX_EPOCH.split("T", maxsplit=1)[0], - end_date=(datetime.now()).isoformat().split("T")[0], ), op_tags={ "dagster-k8s/config": K8S_CONFIG,