[AutoPR datafactory/resource-manager] Add APIs for tumbling window rerun trigger

azure-mgmt-datafactory/azure/mgmt/datafactory/data_factory_management_client.py

@@ -23,6 +23,7 @@
 from .operations.pipeline_runs_operations import PipelineRunsOperations
 from .operations.activity_runs_operations import ActivityRunsOperations
 from .operations.triggers_operations import TriggersOperations
+from .operations.rerun_triggers_operations import RerunTriggersOperations
 from .operations.trigger_runs_operations import TriggerRunsOperations
 from . import models
 
@@ -85,6 +86,8 @@ class DataFactoryManagementClient(SDKClient):
     :vartype activity_runs: azure.mgmt.datafactory.operations.ActivityRunsOperations
     :ivar triggers: Triggers operations
     :vartype triggers: azure.mgmt.datafactory.operations.TriggersOperations
+    :ivar rerun_triggers: RerunTriggers operations
+    :vartype rerun_triggers: azure.mgmt.datafactory.operations.RerunTriggersOperations
     :ivar trigger_runs: TriggerRuns operations
     :vartype trigger_runs: azure.mgmt.datafactory.operations.TriggerRunsOperations
 
@@ -127,5 +130,7 @@ def __init__(
             self._client, self.config, self._serialize, self._deserialize)
         self.triggers = TriggersOperations(
             self._client, self.config, self._serialize, self._deserialize)
+        self.rerun_triggers = RerunTriggersOperations(
+            self._client, self.config, self._serialize, self._deserialize)
         self.trigger_runs = TriggerRunsOperations(
             self._client, self.config, self._serialize, self._deserialize)

azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py

@@ -64,13 +64,30 @@
     from .activity_runs_query_response_py3 import ActivityRunsQueryResponse
     from .trigger_run_py3 import TriggerRun
     from .trigger_runs_query_response_py3 import TriggerRunsQueryResponse
+    from .rerun_tumbling_window_trigger_action_parameters_py3 import RerunTumblingWindowTriggerActionParameters
+    from .rerun_tumbling_window_trigger_py3 import RerunTumblingWindowTrigger
+    from .rerun_trigger_resource_py3 import RerunTriggerResource
     from .operation_display_py3 import OperationDisplay
     from .operation_log_specification_py3 import OperationLogSpecification
     from .operation_metric_availability_py3 import OperationMetricAvailability
     from .operation_metric_dimension_py3 import OperationMetricDimension
     from .operation_metric_specification_py3 import OperationMetricSpecification
     from .operation_service_specification_py3 import OperationServiceSpecification
     from .operation_py3 import Operation
+    from .self_dependency_tumbling_window_trigger_reference_py3 import SelfDependencyTumblingWindowTriggerReference
+    from .trigger_reference_py3 import TriggerReference
+    from .tumbling_window_trigger_dependency_reference_py3 import TumblingWindowTriggerDependencyReference
+    from .trigger_dependency_reference_py3 import TriggerDependencyReference
+    from .dependency_reference_py3 import DependencyReference
+    from .retry_policy_py3 import RetryPolicy
+    from .tumbling_window_trigger_py3 import TumblingWindowTrigger
+    from .blob_events_trigger_py3 import BlobEventsTrigger
+    from .blob_trigger_py3 import BlobTrigger
+    from .recurrence_schedule_occurrence_py3 import RecurrenceScheduleOccurrence
+    from .recurrence_schedule_py3 import RecurrenceSchedule
+    from .schedule_trigger_recurrence_py3 import ScheduleTriggerRecurrence
+    from .schedule_trigger_py3 import ScheduleTrigger
+    from .multiple_pipeline_trigger_py3 import MultiplePipelineTrigger
     from .responsys_linked_service_py3 import ResponsysLinkedService
     from .azure_databricks_linked_service_py3 import AzureDatabricksLinkedService
     from .azure_data_lake_analytics_linked_service_py3 import AzureDataLakeAnalyticsLinkedService
@@ -212,20 +229,6 @@
     from .azure_table_dataset_py3 import AzureTableDataset
     from .azure_blob_dataset_py3 import AzureBlobDataset
     from .amazon_s3_dataset_py3 import AmazonS3Dataset
-    from .self_dependency_tumbling_window_trigger_reference_py3 import SelfDependencyTumblingWindowTriggerReference
-    from .trigger_reference_py3 import TriggerReference
-    from .tumbling_window_trigger_dependency_reference_py3 import TumblingWindowTriggerDependencyReference
-    from .trigger_dependency_reference_py3 import TriggerDependencyReference
-    from .dependency_reference_py3 import DependencyReference
-    from .retry_policy_py3 import RetryPolicy
-    from .tumbling_window_trigger_py3 import TumblingWindowTrigger
-    from .blob_events_trigger_py3 import BlobEventsTrigger
-    from .blob_trigger_py3 import BlobTrigger
-    from .recurrence_schedule_occurrence_py3 import RecurrenceScheduleOccurrence
-    from .recurrence_schedule_py3 import RecurrenceSchedule
-    from .schedule_trigger_recurrence_py3 import ScheduleTriggerRecurrence
-    from .schedule_trigger_py3 import ScheduleTrigger
-    from .multiple_pipeline_trigger_py3 import MultiplePipelineTrigger
     from .activity_policy_py3 import ActivityPolicy
     from .databricks_spark_python_activity_py3 import DatabricksSparkPythonActivity
     from .databricks_spark_jar_activity_py3 import DatabricksSparkJarActivity
@@ -413,13 +416,30 @@
     from .activity_runs_query_response import ActivityRunsQueryResponse
     from .trigger_run import TriggerRun
     from .trigger_runs_query_response import TriggerRunsQueryResponse
+    from .rerun_tumbling_window_trigger_action_parameters import RerunTumblingWindowTriggerActionParameters
+    from .rerun_tumbling_window_trigger import RerunTumblingWindowTrigger
+    from .rerun_trigger_resource import RerunTriggerResource
     from .operation_display import OperationDisplay
     from .operation_log_specification import OperationLogSpecification
     from .operation_metric_availability import OperationMetricAvailability
     from .operation_metric_dimension import OperationMetricDimension
     from .operation_metric_specification import OperationMetricSpecification
     from .operation_service_specification import OperationServiceSpecification
     from .operation import Operation
+    from .self_dependency_tumbling_window_trigger_reference import SelfDependencyTumblingWindowTriggerReference
+    from .trigger_reference import TriggerReference
+    from .tumbling_window_trigger_dependency_reference import TumblingWindowTriggerDependencyReference
+    from .trigger_dependency_reference import TriggerDependencyReference
+    from .dependency_reference import DependencyReference
+    from .retry_policy import RetryPolicy
+    from .tumbling_window_trigger import TumblingWindowTrigger
+    from .blob_events_trigger import BlobEventsTrigger
+    from .blob_trigger import BlobTrigger
+    from .recurrence_schedule_occurrence import RecurrenceScheduleOccurrence
+    from .recurrence_schedule import RecurrenceSchedule
+    from .schedule_trigger_recurrence import ScheduleTriggerRecurrence
+    from .schedule_trigger import ScheduleTrigger
+    from .multiple_pipeline_trigger import MultiplePipelineTrigger
     from .responsys_linked_service import ResponsysLinkedService
     from .azure_databricks_linked_service import AzureDatabricksLinkedService
     from .azure_data_lake_analytics_linked_service import AzureDataLakeAnalyticsLinkedService
@@ -561,20 +581,6 @@
     from .azure_table_dataset import AzureTableDataset
     from .azure_blob_dataset import AzureBlobDataset
     from .amazon_s3_dataset import AmazonS3Dataset
-    from .self_dependency_tumbling_window_trigger_reference import SelfDependencyTumblingWindowTriggerReference
-    from .trigger_reference import TriggerReference
-    from .tumbling_window_trigger_dependency_reference import TumblingWindowTriggerDependencyReference
-    from .trigger_dependency_reference import TriggerDependencyReference
-    from .dependency_reference import DependencyReference
-    from .retry_policy import RetryPolicy
-    from .tumbling_window_trigger import TumblingWindowTrigger
-    from .blob_events_trigger import BlobEventsTrigger
-    from .blob_trigger import BlobTrigger
-    from .recurrence_schedule_occurrence import RecurrenceScheduleOccurrence
-    from .recurrence_schedule import RecurrenceSchedule
-    from .schedule_trigger_recurrence import ScheduleTriggerRecurrence
-    from .schedule_trigger import ScheduleTrigger
-    from .multiple_pipeline_trigger import MultiplePipelineTrigger
     from .activity_policy import ActivityPolicy
     from .databricks_spark_python_activity import DatabricksSparkPythonActivity
     from .databricks_spark_jar_activity import DatabricksSparkJarActivity
@@ -714,6 +720,7 @@
 from .dataset_resource_paged import DatasetResourcePaged
 from .pipeline_resource_paged import PipelineResourcePaged
 from .trigger_resource_paged import TriggerResourcePaged
+from .rerun_trigger_resource_paged import RerunTriggerResourcePaged
 from .data_factory_management_client_enums import (
     IntegrationRuntimeState,
     IntegrationRuntimeAutoUpdate,
@@ -726,6 +733,11 @@
     RunQueryOrderByField,
     RunQueryOrder,
     TriggerRunStatus,
+    TumblingWindowFrequency,
+    BlobEventTypes,
+    DayOfWeek,
+    DaysOfWeek,
+    RecurrenceFrequency,
     SparkServerType,
     SparkThriftTransportProtocol,
     SparkAuthenticationType,
@@ -749,11 +761,6 @@
     SybaseAuthenticationType,
     DatasetCompressionLevel,
     JsonFormatFilePattern,
-    TumblingWindowFrequency,
-    BlobEventTypes,
-    DayOfWeek,
-    DaysOfWeek,
-    RecurrenceFrequency,
     WebActivityMethod,
     CassandraSourceReadConsistencyLevels,
     StoredProcedureParameterType,
@@ -831,13 +838,30 @@
     'ActivityRunsQueryResponse',
     'TriggerRun',
     'TriggerRunsQueryResponse',
+    'RerunTumblingWindowTriggerActionParameters',
+    'RerunTumblingWindowTrigger',
+    'RerunTriggerResource',
     'OperationDisplay',
     'OperationLogSpecification',
     'OperationMetricAvailability',
     'OperationMetricDimension',
     'OperationMetricSpecification',
     'OperationServiceSpecification',
     'Operation',
+    'SelfDependencyTumblingWindowTriggerReference',
+    'TriggerReference',
+    'TumblingWindowTriggerDependencyReference',
+    'TriggerDependencyReference',
+    'DependencyReference',
+    'RetryPolicy',
+    'TumblingWindowTrigger',
+    'BlobEventsTrigger',
+    'BlobTrigger',
+    'RecurrenceScheduleOccurrence',
+    'RecurrenceSchedule',
+    'ScheduleTriggerRecurrence',
+    'ScheduleTrigger',
+    'MultiplePipelineTrigger',
     'ResponsysLinkedService',
     'AzureDatabricksLinkedService',
     'AzureDataLakeAnalyticsLinkedService',
@@ -979,20 +1003,6 @@
     'AzureTableDataset',
     'AzureBlobDataset',
     'AmazonS3Dataset',
-    'SelfDependencyTumblingWindowTriggerReference',
-    'TriggerReference',
-    'TumblingWindowTriggerDependencyReference',
-    'TriggerDependencyReference',
-    'DependencyReference',
-    'RetryPolicy',
-    'TumblingWindowTrigger',
-    'BlobEventsTrigger',
-    'BlobTrigger',
-    'RecurrenceScheduleOccurrence',
-    'RecurrenceSchedule',
-    'ScheduleTriggerRecurrence',
-    'ScheduleTrigger',
-    'MultiplePipelineTrigger',
     'ActivityPolicy',
     'DatabricksSparkPythonActivity',
     'DatabricksSparkJarActivity',
@@ -1132,6 +1142,7 @@
     'DatasetResourcePaged',
     'PipelineResourcePaged',
     'TriggerResourcePaged',
+    'RerunTriggerResourcePaged',
     'IntegrationRuntimeState',
     'IntegrationRuntimeAutoUpdate',
     'ParameterType',
@@ -1143,6 +1154,11 @@
     'RunQueryOrderByField',
     'RunQueryOrder',
     'TriggerRunStatus',
+    'TumblingWindowFrequency',
+    'BlobEventTypes',
+    'DayOfWeek',
+    'DaysOfWeek',
+    'RecurrenceFrequency',
     'SparkServerType',
     'SparkThriftTransportProtocol',
     'SparkAuthenticationType',
@@ -1166,11 +1182,6 @@
     'SybaseAuthenticationType',
     'DatasetCompressionLevel',
     'JsonFormatFilePattern',
-    'TumblingWindowFrequency',
-    'BlobEventTypes',
-    'DayOfWeek',
-    'DaysOfWeek',
-    'RecurrenceFrequency',
     'WebActivityMethod',
     'CassandraSourceReadConsistencyLevels',
     'StoredProcedureParameterType',

azure-mgmt-datafactory/azure/mgmt/datafactory/models/data_factory_management_client_enums.py

@@ -113,6 +113,51 @@ class TriggerRunStatus(str, Enum):
     inprogress = "Inprogress"
 
 
+class TumblingWindowFrequency(str, Enum):
+
+    minute = "Minute"
+    hour = "Hour"
+
+
+class BlobEventTypes(str, Enum):
+
+    microsoft_storage_blob_created = "Microsoft.Storage.BlobCreated"
+    microsoft_storage_blob_deleted = "Microsoft.Storage.BlobDeleted"
+
+
+class DayOfWeek(str, Enum):
+
+    sunday = "Sunday"
+    monday = "Monday"
+    tuesday = "Tuesday"
+    wednesday = "Wednesday"
+    thursday = "Thursday"
+    friday = "Friday"
+    saturday = "Saturday"
+
+
+class DaysOfWeek(str, Enum):
+
+    sunday = "Sunday"
+    monday = "Monday"
+    tuesday = "Tuesday"
+    wednesday = "Wednesday"
+    thursday = "Thursday"
+    friday = "Friday"
+    saturday = "Saturday"
+
+
+class RecurrenceFrequency(str, Enum):
+
+    not_specified = "NotSpecified"
+    minute = "Minute"
+    hour = "Hour"
+    day = "Day"
+    week = "Week"
+    month = "Month"
+    year = "Year"
+
+
 class SparkServerType(str, Enum):
 
     shark_server = "SharkServer"
@@ -263,51 +308,6 @@ class JsonFormatFilePattern(str, Enum):
     array_of_objects = "arrayOfObjects"
 
 
-class TumblingWindowFrequency(str, Enum):
-
-    minute = "Minute"
-    hour = "Hour"
-
-
-class BlobEventTypes(str, Enum):
-
-    microsoft_storage_blob_created = "Microsoft.Storage.BlobCreated"
-    microsoft_storage_blob_deleted = "Microsoft.Storage.BlobDeleted"
-
-
-class DayOfWeek(str, Enum):
-
-    sunday = "Sunday"
-    monday = "Monday"
-    tuesday = "Tuesday"
-    wednesday = "Wednesday"
-    thursday = "Thursday"
-    friday = "Friday"
-    saturday = "Saturday"
-
-
-class DaysOfWeek(str, Enum):
-
-    sunday = "Sunday"
-    monday = "Monday"
-    tuesday = "Tuesday"
-    wednesday = "Wednesday"
-    thursday = "Thursday"
-    friday = "Friday"
-    saturday = "Saturday"
-
-
-class RecurrenceFrequency(str, Enum):
-
-    not_specified = "NotSpecified"
-    minute = "Minute"
-    hour = "Hour"
-    day = "Day"
-    week = "Week"
-    month = "Month"
-    year = "Year"
-
-
 class WebActivityMethod(str, Enum):
 
     get = "GET"