don4of4 commented on pull request #11015:
URL: https://github.com/apache/airflow/pull/11015#issuecomment-782928423
@flvndh this looks very close -- will you be getting a chance to look at
these failing tests?
```
=================================== FAILURES
===================================
____________________ test_update_factory[explicit factory]
_____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8215b93c8>
user_args = (<object object at 0x7ff853117360>, 'testResourceGroup',
'testFactory')
sdk_args = ('testResourceGroup', 'testFactory', <object object at
0x7ff853117360>)
@parametrize(
explicit_factory=((MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, MODEL)),
implicit_factory=((MODEL,), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, MODEL)),
)
def test_update_factory(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_factory(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:137:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8215b93c8>
factory = <object object at 0x7ff853117360>
resource_group_name = 'testResourceGroup', factory_name = 'testFactory'
config = {}
@provide_targeted_factory
def update_factory(
self,
factory: Factory,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> Factory:
"""
Update the factory.
:param factory: The factory resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the factory does not exist.
:return: The factory.
"""
if not self._factory_exists(resource_group_name, factory):
> raise AirflowException(f"Factory {factory!r} does not exist.")
E airflow.exceptions.AirflowException: Factory <object object at
0x7ff853117360> does not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:130:
AirflowException
____________________ test_update_factory[implicit factory]
_____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8215874e0>
user_args = (<object object at 0x7ff853117360>,)
sdk_args = ('defaultResourceGroup', 'defaultFactory', <object object at
0x7ff853117360>)
@parametrize(
explicit_factory=((MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, MODEL)),
implicit_factory=((MODEL,), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, MODEL)),
)
def test_update_factory(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_factory(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:137:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8215874e0>
factory = <object object at 0x7ff853117360>
resource_group_name = 'defaultResourceGroup', factory_name =
'defaultFactory'
config = {}
@provide_targeted_factory
def update_factory(
self,
factory: Factory,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> Factory:
"""
Update the factory.
:param factory: The factory resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the factory does not exist.
:return: The factory.
"""
if not self._factory_exists(resource_group_name, factory):
> raise AirflowException(f"Factory {factory!r} does not exist.")
E airflow.exceptions.AirflowException: Factory <object object at
0x7ff853117360> does not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:130:
AirflowException
_________________ test_update_linked_service[explicit factory]
_________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8202feef0>
user_args = ('testName', <object object at 0x7ff853117360>,
'testResourceGroup', 'testFactory')
sdk_args = ('testResourceGroup', 'testFactory', 'testName', <object object
at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_linked_service(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_linked_service(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:177:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8202feef0>
linked_service_name = 'testName'
linked_service = <object object at 0x7ff853117360>
resource_group_name = 'testResourceGroup', factory_name = 'testFactory'
config = {}
@provide_targeted_factory
def update_linked_service(
self,
linked_service_name: str,
linked_service: LinkedService,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> LinkedServiceResource:
"""
Update the linked service.
:param linked_service_name: The linked service name.
:param linked_service: The linked service resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the linked service does not exist.
:return: The linked service.
"""
if not self._linked_service_exists(resource_group_name,
factory_name, linked_service_name):
> raise AirflowException(f"Linked service
{linked_service_name!r} does not exist.")
E airflow.exceptions.AirflowException: Linked service 'testName'
does not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:227:
AirflowException
_________________ test_update_linked_service[implicit factory]
_________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8202fe710>
user_args = ('testName', <object object at 0x7ff853117360>)
sdk_args = ('defaultResourceGroup', 'defaultFactory', 'testName', <object
object at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_linked_service(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_linked_service(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:177:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8202fe710>
linked_service_name = 'testName'
linked_service = <object object at 0x7ff853117360>
resource_group_name = 'defaultResourceGroup', factory_name =
'defaultFactory'
config = {}
@provide_targeted_factory
def update_linked_service(
self,
linked_service_name: str,
linked_service: LinkedService,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> LinkedServiceResource:
"""
Update the linked service.
:param linked_service_name: The linked service name.
:param linked_service: The linked service resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the linked service does not exist.
:return: The linked service.
"""
if not self._linked_service_exists(resource_group_name,
factory_name, linked_service_name):
> raise AirflowException(f"Linked service
{linked_service_name!r} does not exist.")
E airflow.exceptions.AirflowException: Linked service 'testName'
does not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:227:
AirflowException
____________________ test_update_dataset[explicit factory]
_____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff829e30198>
user_args = ('testName', <object object at 0x7ff853117360>,
'testResourceGroup', 'testFactory')
sdk_args = ('testResourceGroup', 'testFactory', 'testName', <object object
at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_dataset(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_dataset(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:217:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff829e30198>
dataset_name = 'testName', dataset = <object object at 0x7ff853117360>
resource_group_name = 'testResourceGroup', factory_name = 'testFactory'
config = {}
@provide_targeted_factory
def update_dataset(
self,
dataset_name: str,
dataset: Dataset,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> DatasetResource:
"""
Update the dataset.
:param dataset_name: The dataset name.
:param dataset: The dataset resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the dataset does not exist.
:return: The dataset.
"""
if not self._dataset_exists(resource_group_name, factory_name,
dataset_name):
> raise AirflowException(f"Dataset {dataset_name!r} does not
exist.")
E airflow.exceptions.AirflowException: Dataset 'testName' does
not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:329:
AirflowException
____________________ test_update_dataset[implicit factory]
_____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff82a063400>
user_args = ('testName', <object object at 0x7ff853117360>)
sdk_args = ('defaultResourceGroup', 'defaultFactory', 'testName', <object
object at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_dataset(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_dataset(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:217:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff82a063400>
dataset_name = 'testName', dataset = <object object at 0x7ff853117360>
resource_group_name = 'defaultResourceGroup', factory_name =
'defaultFactory'
config = {}
@provide_targeted_factory
def update_dataset(
self,
dataset_name: str,
dataset: Dataset,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> DatasetResource:
"""
Update the dataset.
:param dataset_name: The dataset name.
:param dataset: The dataset resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the dataset does not exist.
:return: The dataset.
"""
if not self._dataset_exists(resource_group_name, factory_name,
dataset_name):
> raise AirflowException(f"Dataset {dataset_name!r} does not
exist.")
E airflow.exceptions.AirflowException: Dataset 'testName' does
not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:329:
AirflowException
____________________ test_update_pipeline[explicit factory]
____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8231ae198>
user_args = ('testName', <object object at 0x7ff853117360>,
'testResourceGroup', 'testFactory')
sdk_args = ('testResourceGroup', 'testFactory', 'testName', <object object
at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_pipeline(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_pipeline(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:257:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff8231ae198>
pipeline_name = 'testName', pipeline = <object object at 0x7ff853117360>
resource_group_name = 'testResourceGroup', factory_name = 'testFactory'
config = {}
@provide_targeted_factory
def update_pipeline(
self,
pipeline_name: str,
pipeline: PipelineResource,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> PipelineResource:
"""
Update the pipeline.
:param pipeline_name: The pipeline name.
:param pipeline: The pipeline resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the pipeline does not exist.
:return: The pipeline.
"""
if not self._pipeline_exists(resource_group_name, factory_name,
pipeline_name):
> raise AirflowException(f"Pipeline {pipeline_name!r} does not
exist.")
E airflow.exceptions.AirflowException: Pipeline 'testName' does
not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:429:
AirflowException
____________________ test_update_pipeline[implicit factory]
____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff81bf956d8>
user_args = ('testName', <object object at 0x7ff853117360>)
sdk_args = ('defaultResourceGroup', 'defaultFactory', 'testName', <object
object at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_pipeline(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_pipeline(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:257:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff81bf956d8>
pipeline_name = 'testName', pipeline = <object object at 0x7ff853117360>
resource_group_name = 'defaultResourceGroup', factory_name =
'defaultFactory'
config = {}
@provide_targeted_factory
def update_pipeline(
self,
pipeline_name: str,
pipeline: PipelineResource,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> PipelineResource:
"""
Update the pipeline.
:param pipeline_name: The pipeline name.
:param pipeline: The pipeline resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the pipeline does not exist.
:return: The pipeline.
"""
if not self._pipeline_exists(resource_group_name, factory_name,
pipeline_name):
> raise AirflowException(f"Pipeline {pipeline_name!r} does not
exist.")
E airflow.exceptions.AirflowException: Pipeline 'testName' does
not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:429:
AirflowException
____________________ test_update_trigger[explicit factory]
_____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff81adab5f8>
user_args = ('testName', <object object at 0x7ff853117360>,
'testResourceGroup', 'testFactory')
sdk_args = ('testResourceGroup', 'testFactory', 'testName', <object object
at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_trigger(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_trigger(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:327:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff81adab5f8>
trigger_name = 'testName', trigger = <object object at 0x7ff853117360>
resource_group_name = 'testResourceGroup', factory_name = 'testFactory'
config = {}
@provide_targeted_factory
def update_trigger(
self,
trigger_name: str,
trigger: Trigger,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> TriggerResource:
"""
Update the trigger.
:param trigger_name: The trigger name.
:param trigger: The trigger resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the trigger does not exist.
:return: The trigger.
"""
if not self._trigger_exists(resource_group_name, factory_name,
trigger_name):
> raise AirflowException(f"Trigger {trigger_name!r} does not
exist.")
E airflow.exceptions.AirflowException: Trigger 'testName' does
not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:587:
AirflowException
____________________ test_update_trigger[implicit factory]
_____________________
hook =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff81adabc18>
user_args = ('testName', <object object at 0x7ff853117360>)
sdk_args = ('defaultResourceGroup', 'defaultFactory', 'testName', <object
object at 0x7ff853117360>)
@parametrize(
explicit_factory=((NAME, MODEL, RESOURCE_GROUP, FACTORY),
(RESOURCE_GROUP, FACTORY, NAME, MODEL)),
implicit_factory=((NAME, MODEL), (DEFAULT_RESOURCE_GROUP,
DEFAULT_FACTORY, NAME, MODEL)),
)
def test_update_trigger(hook: AzureDataFactoryHook, user_args,
sdk_args):
> hook.update_trigger(*user_args)
tests/providers/microsoft/azure/hooks/test_azure_data_factory.py:327:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:67: in
wrapper
return func(*bound_args.args, **bound_args.kwargs)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _
self =
<airflow.providers.microsoft.azure.hooks.azure_data_factory.AzureDataFactoryHook
object at 0x7ff81adabc18>
trigger_name = 'testName', trigger = <object object at 0x7ff853117360>
resource_group_name = 'defaultResourceGroup', factory_name =
'defaultFactory'
config = {}
@provide_targeted_factory
def update_trigger(
self,
trigger_name: str,
trigger: Trigger,
resource_group_name: Optional[str] = None,
factory_name: Optional[str] = None,
**config: Any,
) -> TriggerResource:
"""
Update the trigger.
:param trigger_name: The trigger name.
:param trigger: The trigger resource definition.
:param resource_group_name: The resource group name.
:param factory_name: The factory name.
:param config: Extra parameters for the ADF client.
:raise AirflowException: If the trigger does not exist.
:return: The trigger.
"""
if not self._trigger_exists(resource_group_name, factory_name,
trigger_name):
> raise AirflowException(f"Trigger {trigger_name!r} does not
exist.")
E airflow.exceptions.AirflowException: Trigger 'testName' does
not exist.
airflow/providers/microsoft/azure/hooks/azure_data_factory.py:587:
AirflowException
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
