ruạṛ
a ���f�N � @ sD d dl mZ ddlmZmZmZ ddlmZ eG dd� de��ZdS )� )�Operator� )�formatted_flat_dict� NONE_SENTINEL�#value_allowed_none_or_none_sentinel)� init_model_state_from_kwargsc @ s^ e Zd ZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZd Zd Zd Zd Zd ZdZdd� Zedd� �Zejdd� �Zedd� �Zejdd� �Zedd� �Zejdd� �Zedd� �Zejd d� �Zed d � �Z e jd d � �Z ed d!� �Z e jd"d!� �Z ed#d$� �Z e jd%d$� �Z ed&d'� �Z e jd(d'� �Z ed)d*� �Z e jd+d*� �Z d,d-� Z!d.d/� Z"d0d1� Z#d2S )3� TaskOperatorz An operator for task �SECONDS�MINUTES�HOURS�DAYS� PIPELINE_TASK�INTEGRATION_TASK�DATA_LOADER_TASK�SQL_TASK�OCI_DATAFLOW_TASK� REST_TASK� ALL_SUCCESS� ALL_FAILED� ALL_COMPLETEc K s� dddddddddddddddddddd dd d �| _ d d ddddddddddddddd d d d d d!d �| _d"| _d"| _d"| _d"| _d"| _d"| _d"| _d"| _ d"| _ d"| _ d"| _ d"| _ d"| _d"| _d"| _d"| _d"| _d"| _d"| _d"| _d"| _d"| _d#| _d"S )$a� Initializes a new TaskOperator object with values from keyword arguments. The default value of the :py:attr:`~oci.data_integration.models.TaskOperator.model_type` attribute of this class is ``TASK_OPERATOR`` and it should not be changed. The following keyword arguments are supported (corresponding to the getters/setters of this class): :param model_type: The value to assign to the model_type property of this TaskOperator. Allowed values for this property are: "SOURCE_OPERATOR", "FILTER_OPERATOR", "JOINER_OPERATOR", "AGGREGATOR_OPERATOR", "PROJECTION_OPERATOR", "TARGET_OPERATOR", "FLATTEN_OPERATOR", "DISTINCT_OPERATOR", "SORT_OPERATOR", "UNION_OPERATOR", "INTERSECT_OPERATOR", "MINUS_OPERATOR", "MERGE_OPERATOR", "FUNCTION_OPERATOR", "SPLIT_OPERATOR", "START_OPERATOR", "END_OPERATOR", "PIPELINE_OPERATOR", "DECISION_OPERATOR", "TASK_OPERATOR", "EXPRESSION_OPERATOR", "LOOKUP_OPERATOR", "PIVOT_OPERATOR", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type model_type: str :param key: The value to assign to the key property of this TaskOperator. :type key: str :param model_version: The value to assign to the model_version property of this TaskOperator. :type model_version: str :param parent_ref: The value to assign to the parent_ref property of this TaskOperator. :type parent_ref: oci.data_integration.models.ParentReference :param name: The value to assign to the name property of this TaskOperator. :type name: str :param description: The value to assign to the description property of this TaskOperator. :type description: str :param object_version: The value to assign to the object_version property of this TaskOperator. :type object_version: int :param input_ports: The value to assign to the input_ports property of this TaskOperator. :type input_ports: list[oci.data_integration.models.InputPort] :param output_ports: The value to assign to the output_ports property of this TaskOperator. :type output_ports: list[oci.data_integration.models.TypedObject] :param object_status: The value to assign to the object_status property of this TaskOperator. :type object_status: int :param identifier: The value to assign to the identifier property of this TaskOperator. :type identifier: str :param parameters: The value to assign to the parameters property of this TaskOperator. :type parameters: list[oci.data_integration.models.Parameter] :param op_config_values: The value to assign to the op_config_values property of this TaskOperator. :type op_config_values: oci.data_integration.models.ConfigValues :param retry_attempts: The value to assign to the retry_attempts property of this TaskOperator. :type retry_attempts: int :param retry_delay_unit: The value to assign to the retry_delay_unit property of this TaskOperator. Allowed values for this property are: "SECONDS", "MINUTES", "HOURS", "DAYS", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type retry_delay_unit: str :param retry_delay: The value to assign to the retry_delay property of this TaskOperator. :type retry_delay: float :param expected_duration: The value to assign to the expected_duration property of this TaskOperator. :type expected_duration: float :param expected_duration_unit: The value to assign to the expected_duration_unit property of this TaskOperator. Allowed values for this property are: "SECONDS", "MINUTES", "HOURS", "DAYS", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type expected_duration_unit: str :param task_type: The value to assign to the task_type property of this TaskOperator. Allowed values for this property are: "PIPELINE_TASK", "INTEGRATION_TASK", "DATA_LOADER_TASK", "SQL_TASK", "OCI_DATAFLOW_TASK", "REST_TASK", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type task_type: str :param task: The value to assign to the task property of this TaskOperator. :type task: oci.data_integration.models.Task :param trigger_rule: The value to assign to the trigger_rule property of this TaskOperator. Allowed values for this property are: "ALL_SUCCESS", "ALL_FAILED", "ALL_COMPLETE", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type trigger_rule: str :param config_provider_delegate: The value to assign to the config_provider_delegate property of this TaskOperator. :type config_provider_delegate: oci.data_integration.models.ConfigProvider �strZParentReference�intzlist[InputPort]zlist[TypedObject]zlist[Parameter]Z ConfigValues�floatZTaskZConfigProvider)Z model_type�keyZ model_versionZ parent_ref�name� descriptionZobject_versionZ input_portsZ output_portsZ object_status� identifier� parametersZop_config_values�retry_attempts�retry_delay_unit� retry_delay�expected_duration�expected_duration_unit� task_type�task� trigger_rule�config_provider_delegateZ modelTyper Z modelVersionZ parentRefr r Z objectVersionZ inputPortsZ outputPortsZ objectStatusr r ZopConfigValuesZ retryAttemptsZretryDelayUnitZ retryDelayZexpectedDurationZexpectedDurationUnitZtaskTyper$ Z triggerRuleZconfigProviderDelegateNZ TASK_OPERATOR)Z swagger_typesZ attribute_mapZ _model_typeZ_keyZ_model_versionZ _parent_ref�_nameZ _descriptionZ_object_versionZ _input_portsZ _output_portsZ_object_statusZ _identifierZ _parametersZ_op_config_values�_retry_attempts�_retry_delay_unit� _retry_delay�_expected_duration�_expected_duration_unit� _task_type�_task� _trigger_rule�_config_provider_delegate)�self�kwargs� r3 �M/usr/lib/python3.9/site-packages/oci/data_integration/models/task_operator.py�__init__V s� j��zTaskOperator.__init__c C s | j S )z� Gets the retry_attempts of this TaskOperator. The number of retry attempts. :return: The retry_attempts of this TaskOperator. :rtype: int �r( �r1 r3 r3 r4 r s zTaskOperator.retry_attemptsc C s || _ dS )z� Sets the retry_attempts of this TaskOperator. The number of retry attempts. :param retry_attempts: The retry_attempts of this TaskOperator. :type: int Nr6 )r1 r r3 r3 r4 r s c C s | j S )a� Gets the retry_delay_unit of this TaskOperator. The unit for the retry delay. Allowed values for this property are: "SECONDS", "MINUTES", "HOURS", "DAYS", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :return: The retry_delay_unit of this TaskOperator. :rtype: str )r) r7 r3 r3 r4 r ! s z TaskOperator.retry_delay_unitc C s g d�}t ||�sd}|| _dS )z� Sets the retry_delay_unit of this TaskOperator. The unit for the retry delay. :param retry_delay_unit: The retry_delay_unit of this TaskOperator. :type: str �r r r r �UNKNOWN_ENUM_VALUEN)r r) )r1 r �allowed_valuesr3 r3 r4 r 0 s c C s | j S )z� Gets the retry_delay of this TaskOperator. The retry delay, the unit for measurement is in the property retry delay unit. :return: The retry_delay of this TaskOperator. :rtype: float �r* r7 r3 r3 r4 r ? s zTaskOperator.retry_delayc C s || _ dS )z� Sets the retry_delay of this TaskOperator. The retry delay, the unit for measurement is in the property retry delay unit. :param retry_delay: The retry_delay of this TaskOperator. :type: float Nr; )r1 r r3 r3 r4 r K s c C s | j S )z� Gets the expected_duration of this TaskOperator. The expected duration for the task run. :return: The expected_duration of this TaskOperator. :rtype: float �r+ r7 r3 r3 r4 r! W s z TaskOperator.expected_durationc C s || _ dS )z� Sets the expected_duration of this TaskOperator. The expected duration for the task run. :param expected_duration: The expected_duration of this TaskOperator. :type: float Nr< )r1 r! r3 r3 r4 r! c s c C s | j S )a� Gets the expected_duration_unit of this TaskOperator. The expected duration unit of measure. Allowed values for this property are: "SECONDS", "MINUTES", "HOURS", "DAYS", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :return: The expected_duration_unit of this TaskOperator. :rtype: str )r, r7 r3 r3 r4 r" o s z#TaskOperator.expected_duration_unitc C s g d�}t ||�sd}|| _dS )z� Sets the expected_duration_unit of this TaskOperator. The expected duration unit of measure. :param expected_duration_unit: The expected_duration_unit of this TaskOperator. :type: str r8 r9 N)r r, )r1 r" r: r3 r3 r4 r" ~ s c C s | j S )a� Gets the task_type of this TaskOperator. The type of the task referenced in the task property. Allowed values for this property are: "PIPELINE_TASK", "INTEGRATION_TASK", "DATA_LOADER_TASK", "SQL_TASK", "OCI_DATAFLOW_TASK", "REST_TASK", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :return: The task_type of this TaskOperator. :rtype: str )r- r7 r3 r3 r4 r# � s zTaskOperator.task_typec C s g d�}t ||�sd}|| _dS )z� Sets the task_type of this TaskOperator. The type of the task referenced in the task property. :param task_type: The task_type of this TaskOperator. :type: str )r r r r r r r9 N)r r- )r1 r# r: r3 r3 r4 r# � s c C s | j S )z� Gets the task of this TaskOperator. :return: The task of this TaskOperator. :rtype: oci.data_integration.models.Task �r. r7 r3 r3 r4 r$ � s zTaskOperator.taskc C s || _ dS )z� Sets the task of this TaskOperator. :param task: The task of this TaskOperator. :type: oci.data_integration.models.Task Nr= )r1 r$ r3 r3 r4 r$ � s c C s | j S )a� Gets the trigger_rule of this TaskOperator. The merge condition. The conditions are ALL_SUCCESS - All the preceeding operators need to be successful. ALL_FAILED - All the preceeding operators should have failed. ALL_COMPLETE - All the preceeding operators should have completed. It could have executed successfully or failed. Allowed values for this property are: "ALL_SUCCESS", "ALL_FAILED", "ALL_COMPLETE", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :return: The trigger_rule of this TaskOperator. :rtype: str )r/ r7 r3 r3 r4 r% � s zTaskOperator.trigger_rulec C s g d�}t ||�sd}|| _dS )a� Sets the trigger_rule of this TaskOperator. The merge condition. The conditions are ALL_SUCCESS - All the preceeding operators need to be successful. ALL_FAILED - All the preceeding operators should have failed. ALL_COMPLETE - All the preceeding operators should have completed. It could have executed successfully or failed. :param trigger_rule: The trigger_rule of this TaskOperator. :type: str )r r r r9 N)r r/ )r1 r% r: r3 r3 r4 r% � s c C s | j S )z� Gets the config_provider_delegate of this TaskOperator. :return: The config_provider_delegate of this TaskOperator. :rtype: oci.data_integration.models.ConfigProvider �r0 r7 r3 r3 r4 r& � s z%TaskOperator.config_provider_delegatec C s || _ dS )z� Sets the config_provider_delegate of this TaskOperator. :param config_provider_delegate: The config_provider_delegate of this TaskOperator. :type: oci.data_integration.models.ConfigProvider Nr> )r1 r& r3 r3 r4 r& � s c C s t | �S �N)r r7 r3 r3 r4 �__repr__� s zTaskOperator.__repr__c C s |d u r dS | j |j kS )NF)�__dict__�r1 �otherr3 r3 r4 �__eq__� s zTaskOperator.__eq__c C s | |k S r? r3 rB r3 r3 r4 �__ne__ s zTaskOperator.__ne__N)$�__name__� __module__� __qualname__�__doc__ZRETRY_DELAY_UNIT_SECONDSZRETRY_DELAY_UNIT_MINUTESZRETRY_DELAY_UNIT_HOURSZRETRY_DELAY_UNIT_DAYSZ EXPECTED_DURATION_UNIT_SECONDSZ EXPECTED_DURATION_UNIT_MINUTESZ EXPECTED_DURATION_UNIT_HOURSZEXPECTED_DURATION_UNIT_DAYSZTASK_TYPE_PIPELINE_TASKZTASK_TYPE_INTEGRATION_TASKZTASK_TYPE_DATA_LOADER_TASKZTASK_TYPE_SQL_TASKZTASK_TYPE_OCI_DATAFLOW_TASKZTASK_TYPE_REST_TASKZTRIGGER_RULE_ALL_SUCCESSZTRIGGER_RULE_ALL_FAILEDZTRIGGER_RULE_ALL_COMPLETEr5 �propertyr �setterr r r! r" r# r$ r% r& r@ rD rE r3 r3 r3 r4 r sv 4 r N) �operatorr Zoci.utilr r r Zoci.decoratorsr r r3 r3 r3 r4 �<module> s
cải xoăn