Remove OpExecutionContext

dagster-io · Dec 19, 2024 · c543523 · c543523
1 parent 428b5a8
commit c543523
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py
@@ -6,7 +6,7 @@
 from abc import abstractmethod
 from contextlib import contextmanager
 from datetime import datetime, timedelta
-from typing import Any, Dict, List, Mapping, Optional, Sequence, Union, cast
+from typing import Any, Dict, List, Mapping, Optional, Sequence, cast
 
 import requests
 from dagster import (
@@ -15,7 +15,6 @@
     Definitions,
     Failure,
     InitResourceContext,
-    OpExecutionContext,
     _check as check,
     get_dagster_logger,
     resource,
@@ -1212,9 +1211,7 @@ def load_asset_specs(
             workspace=self, dagster_airbyte_translator=dagster_airbyte_translator
         )
 
-    def sync_and_poll(
-        self, context: Optional[Union[OpExecutionContext, AssetExecutionContext]] = None
-    ):
+    def sync_and_poll(self, context: AssetExecutionContext):
         raise NotImplementedError()