From c48ad8af11cd20d8ba4c792595ddcaf1eac1e033 Mon Sep 17 00:00:00 2001 From: Maxime Armstrong Date: Wed, 18 Dec 2024 21:36:13 -0500 Subject: [PATCH] Remove OpExecutionContext --- .../libraries/dagster-airbyte/dagster_airbyte/resources.py | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index ea6730cbe046e..d6ba0d0ea0308 100644 --- 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()