fix py3.9 compatibility

epoch8 · Dec 15, 2024 · a2424b3 · a2424b3
1 parent d405e2f
commit a2424b3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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()