potiuk commented on code in PR #47993:
URL: https://github.com/apache/airflow/pull/47993#discussion_r2042220738
##########
providers/apache/beam/src/airflow/providers/apache/beam/operators/beam.py:
##########
@@ -38,22 +40,27 @@
from airflow.providers.google.cloud.hooks.dataflow import (
DEFAULT_DATAFLOW_LOCATION,
DataflowHook,
- DataflowJobStatus,
process_line_and_extract_dataflow_job_id_callback,
)
from airflow.providers.google.cloud.hooks.gcs import GCSHook, _parse_gcs_url
from airflow.providers.google.cloud.links.dataflow import DataflowJobLink
from airflow.providers.google.cloud.operators.dataflow import CheckJobRunning,
DataflowConfiguration
from airflow.providers.google.cloud.triggers.dataflow import (
+ DataflowJobStateCompleteTrigger,
+ DataflowJobStatus,
DataflowJobStatusTrigger,
)
+from airflow.providers_manager import ProvidersManager
from airflow.utils.helpers import convert_camel_to_snake, exactly_one
from airflow.version import version
if TYPE_CHECKING:
from airflow.utils.context import Context
+GOOGLE_PROVIDER_VERSION =
ProvidersManager().providers["apache-airflow-providers-google"].version
Review Comment:
Yeah. But I guess we should make it into OptionalProviderFeatureException.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
