diff --git a/airflow/providers/microsoft/azure/operators/data_factory.py b/airflow/providers/microsoft/azure/operators/data_factory.py index f1afb35a7c052..afc83cf8c229a 100644 --- a/airflow/providers/microsoft/azure/operators/data_factory.py +++ b/airflow/providers/microsoft/azure/operators/data_factory.py @@ -48,11 +48,8 @@ def get_link( *, ti_key: TaskInstanceKey, ) -> str: - if not isinstance(operator, AzureDataFactoryRunPipelineOperator): - self.log.info("The %s is not %s class.", operator.__class__, AzureDataFactoryRunPipelineOperator) - return "" run_id = XCom.get_value(key="run_id", ti_key=ti_key) - conn_id = operator.azure_data_factory_conn_id + conn_id = operator.azure_data_factory_conn_id # type: ignore conn = BaseHook.get_connection(conn_id) extras = conn.extra_dejson subscription_id = get_field(extras, "subscriptionId") @@ -60,8 +57,10 @@ def get_link( raise KeyError(f"Param subscriptionId not found in conn_id '{conn_id}'") # Both Resource Group Name and Factory Name can either be declared in the Azure Data Factory # connection or passed directly to the operator. - resource_group_name = operator.resource_group_name or get_field(extras, "resource_group_name") - factory_name = operator.factory_name or get_field(extras, "factory_name") + resource_group_name = operator.resource_group_name or get_field( # type: ignore + extras, "resource_group_name" + ) + factory_name = operator.factory_name or get_field(extras, "factory_name") # type: ignore url = ( f"https://adf.azure.com/en-us/monitoring/pipelineruns/{run_id}" f"?factory=/subscriptions/{subscription_id}/"