From a2424b31a9ce7be2195099e4a0a3835020418aa5 Mon Sep 17 00:00:00 2001 From: Andrey Tatarinov Date: Mon, 16 Dec 2024 00:09:12 +0400 Subject: [PATCH] fix py3.9 compatibility --- datapipe/compute.py | 4 ++-- datapipe/step/batch_transform.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/datapipe/compute.py b/datapipe/compute.py index 326b7eba..bae97983 100644 --- a/datapipe/compute.py +++ b/datapipe/compute.py @@ -253,7 +253,7 @@ def __init__( ds: DataStore, catalog: Catalog, pipeline: Pipeline, - executor: Executor | None = None, + executor: Optional[Executor] = None, ): self.ds = ds self.catalog = catalog @@ -285,7 +285,7 @@ def ingest_data( self, table_name: str, data_df: pd.DataFrame, - now: float | None = None, + now: Optional[float] = None, ) -> ChangeList: table = self.ds.get_table(table_name) now = now or time.time() diff --git a/datapipe/step/batch_transform.py b/datapipe/step/batch_transform.py index a25a30e6..9e200f82 100644 --- a/datapipe/step/batch_transform.py +++ b/datapipe/step/batch_transform.py @@ -406,8 +406,8 @@ def notify_change_list( self, ds: DataStore, change_list: ChangeList, - now: float | None = None, - run_config: RunConfig | None = None, + now: Optional[float] = None, + run_config: Optional[RunConfig] = None, ) -> None: now = now or time.time()