ruạṛ
a ���f0� � @ s8 d dl mZmZmZ d dlmZ eG dd� de��ZdS )� )�formatted_flat_dict� NONE_SENTINEL�#value_allowed_none_or_none_sentinel)�init_model_state_from_kwargsc @ s� e Zd ZdZdZdZdZdZdZdZ dZ d Zd ZdZ dZd ZdZdZdZdd� Zedd� �Zejdd� �Zedd� �Zejdd� �Zedd� �Zejdd� �Zedd� �Zejdd� �Zedd � �Zejd!d � �Zed"d#� �Zejd$d#� �Zed%d&� �Zejd'd&� �Zed(d)� �Zejd*d)� �Zed+d,� �Zejd-d,� �Zed.d/� �Zejd0d/� �Zed1d2� �Z e jd3d2� �Z ed4d5� �Z!e!jd6d5� �Z!ed7d8� �Z"e"jd9d8� �Z"ed:d;� �Z#e#jd<d;� �Z#ed=d>� �Z$e$jd?d>� �Z$ed@dA� �Z%e%jdBdA� �Z%edCdD� �Z&e&jdEdD� �Z&edFdG� �Z'e'jdHdG� �Z'edIdJ� �Z(e(jdKdJ� �Z(edLdM� �Z)e)jdNdM� �Z)edOdP� �Z*e*jdQdP� �Z*edRdS� �Z+e+jdTdS� �Z+edUdV� �Z,e,jdWdV� �Z,edXdY� �Z-e-jdZdY� �Z-ed[d\� �Z.e.jd]d\� �Z.ed^d_� �Z/e/jd`d_� �Z/edadb� �Z0e0jdcdb� �Z0eddde� �Z1e1jdfde� �Z1edgdh� �Z2e2jdidh� �Z2edjdk� �Z3e3jdldk� �Z3edmdn� �Z4e4jdodn� �Z4edpdq� �Z5e5jdrdq� �Z5edsdt� �Z6e6jdudt� �Z6edvdw� �Z7e7jdxdw� �Z7edydz� �Z8e8jd{dz� �Z8ed|d}� �Z9e9jd~d}� �Z9edd�� �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>ed�d�� �Z?e?jd�d�� �Z?ed�d�� �Z@e@jd�d�� �Z@ed�d�� �ZAeAjd�d�� �ZAd�d�� ZBd�d�� ZCd�d�� ZDd�S )��Runz A run object. �SCALA�JAVA�PYTHON�SQL�ACCEPTED�IN_PROGRESS� CANCELING�CANCELED�FAILED� SUCCEEDED�STOPPING�STOPPED�BATCH� STREAMING�SESSIONc - K s� dddddddddddddddddddddddddddddddddddddd d dddddd �,| _ ddd ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d �,| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _ d7| _ d7| _d7| _d7| _ d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _d7| _ d7| _!d7| _"d7| _#d7| _$d7| _%d7| _&d7| _'d7| _(d7| _)d7| _*d7| _+d7| _,d7| _-d7S )8a= Initializes a new Run object with values from keyword arguments. The following keyword arguments are supported (corresponding to the getters/setters of this class): :param archive_uri: The value to assign to the archive_uri property of this Run. :type archive_uri: str :param arguments: The value to assign to the arguments property of this Run. :type arguments: list[str] :param application_id: The value to assign to the application_id property of this Run. :type application_id: str :param application_log_config: The value to assign to the application_log_config property of this Run. :type application_log_config: oci.data_flow.models.ApplicationLogConfig :param class_name: The value to assign to the class_name property of this Run. :type class_name: str :param compartment_id: The value to assign to the compartment_id property of this Run. :type compartment_id: str :param configuration: The value to assign to the configuration property of this Run. :type configuration: dict(str, str) :param data_read_in_bytes: The value to assign to the data_read_in_bytes property of this Run. :type data_read_in_bytes: int :param data_written_in_bytes: The value to assign to the data_written_in_bytes property of this Run. :type data_written_in_bytes: int :param defined_tags: The value to assign to the defined_tags property of this Run. :type defined_tags: dict(str, dict(str, object)) :param display_name: The value to assign to the display_name property of this Run. :type display_name: str :param driver_shape: The value to assign to the driver_shape property of this Run. :type driver_shape: str :param driver_shape_config: The value to assign to the driver_shape_config property of this Run. :type driver_shape_config: oci.data_flow.models.ShapeConfig :param execute: The value to assign to the execute property of this Run. :type execute: str :param executor_shape: The value to assign to the executor_shape property of this Run. :type executor_shape: str :param executor_shape_config: The value to assign to the executor_shape_config property of this Run. :type executor_shape_config: oci.data_flow.models.ShapeConfig :param file_uri: The value to assign to the file_uri property of this Run. :type file_uri: str :param freeform_tags: The value to assign to the freeform_tags property of this Run. :type freeform_tags: dict(str, str) :param id: The value to assign to the id property of this Run. :type id: str :param language: The value to assign to the language property of this Run. Allowed values for this property are: "SCALA", "JAVA", "PYTHON", "SQL", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type language: str :param lifecycle_details: The value to assign to the lifecycle_details property of this Run. :type lifecycle_details: str :param lifecycle_state: The value to assign to the lifecycle_state property of this Run. Allowed values for this property are: "ACCEPTED", "IN_PROGRESS", "CANCELING", "CANCELED", "FAILED", "SUCCEEDED", "STOPPING", "STOPPED", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type lifecycle_state: str :param logs_bucket_uri: The value to assign to the logs_bucket_uri property of this Run. :type logs_bucket_uri: str :param metastore_id: The value to assign to the metastore_id property of this Run. :type metastore_id: str :param num_executors: The value to assign to the num_executors property of this Run. :type num_executors: int :param opc_request_id: The value to assign to the opc_request_id property of this Run. :type opc_request_id: str :param owner_principal_id: The value to assign to the owner_principal_id property of this Run. :type owner_principal_id: str :param owner_user_name: The value to assign to the owner_user_name property of this Run. :type owner_user_name: str :param parameters: The value to assign to the parameters property of this Run. :type parameters: list[oci.data_flow.models.ApplicationParameter] :param pool_id: The value to assign to the pool_id property of this Run. :type pool_id: str :param private_endpoint_dns_zones: The value to assign to the private_endpoint_dns_zones property of this Run. :type private_endpoint_dns_zones: list[str] :param private_endpoint_max_host_count: The value to assign to the private_endpoint_max_host_count property of this Run. :type private_endpoint_max_host_count: int :param private_endpoint_nsg_ids: The value to assign to the private_endpoint_nsg_ids property of this Run. :type private_endpoint_nsg_ids: list[str] :param private_endpoint_id: The value to assign to the private_endpoint_id property of this Run. :type private_endpoint_id: str :param private_endpoint_subnet_id: The value to assign to the private_endpoint_subnet_id property of this Run. :type private_endpoint_subnet_id: str :param run_duration_in_milliseconds: The value to assign to the run_duration_in_milliseconds property of this Run. :type run_duration_in_milliseconds: int :param spark_version: The value to assign to the spark_version property of this Run. :type spark_version: str :param time_created: The value to assign to the time_created property of this Run. :type time_created: datetime :param time_updated: The value to assign to the time_updated property of this Run. :type time_updated: datetime :param total_o_cpu: The value to assign to the total_o_cpu property of this Run. :type total_o_cpu: int :param type: The value to assign to the type property of this Run. Allowed values for this property are: "BATCH", "STREAMING", "SESSION", 'UNKNOWN_ENUM_VALUE'. Any unrecognized values returned by a service will be mapped to 'UNKNOWN_ENUM_VALUE'. :type type: str :param warehouse_bucket_uri: The value to assign to the warehouse_bucket_uri property of this Run. :type warehouse_bucket_uri: str :param max_duration_in_minutes: The value to assign to the max_duration_in_minutes property of this Run. :type max_duration_in_minutes: int :param idle_timeout_in_minutes: The value to assign to the idle_timeout_in_minutes property of this Run. :type idle_timeout_in_minutes: int �strz list[str]ZApplicationLogConfigzdict(str, str)�intzdict(str, dict(str, object))ZShapeConfigzlist[ApplicationParameter]Zdatetime),�archive_uri� arguments�application_id�application_log_config� class_name�compartment_id� configuration�data_read_in_bytes�data_written_in_bytes�defined_tags�display_name�driver_shape�driver_shape_config�execute�executor_shape�executor_shape_config�file_uri� freeform_tags�id�language�lifecycle_details�lifecycle_state�logs_bucket_uri�metastore_id� num_executors�opc_request_id�owner_principal_id�owner_user_name� parameters�pool_id�private_endpoint_dns_zones�private_endpoint_max_host_count�private_endpoint_nsg_ids�private_endpoint_id�private_endpoint_subnet_id�run_duration_in_milliseconds� spark_version�time_created�time_updated�total_o_cpu�type�warehouse_bucket_uri�max_duration_in_minutes�idle_timeout_in_minutesZ archiveUrir Z applicationIdZapplicationLogConfigZ classNameZ compartmentIdr ZdataReadInBytesZdataWrittenInBytesZdefinedTagsZdisplayNameZdriverShapeZdriverShapeConfigr% Z executorShapeZexecutorShapeConfigZfileUriZfreeformTagsr* r+ ZlifecycleDetailsZlifecycleStateZ logsBucketUriZmetastoreIdZnumExecutorsZopcRequestIdZownerPrincipalIdZ ownerUserNamer4 ZpoolIdZprivateEndpointDnsZonesZprivateEndpointMaxHostCountZprivateEndpointNsgIdsZprivateEndpointIdZprivateEndpointSubnetIdZrunDurationInMillisecondsZsparkVersionZtimeCreatedZtimeUpdatedZ totalOCpur@ ZwarehouseBucketUriZmaxDurationInMinutesZidleTimeoutInMinutesN).Z swagger_typesZ attribute_map�_archive_uri� _arguments�_application_id�_application_log_config�_class_name�_compartment_id�_configuration�_data_read_in_bytes�_data_written_in_bytes� _defined_tags� _display_name� _driver_shape�_driver_shape_config�_execute�_executor_shape�_executor_shape_config� _file_uri�_freeform_tags�_id� _language�_lifecycle_details�_lifecycle_state�_logs_bucket_uri� _metastore_id�_num_executors�_opc_request_id�_owner_principal_id�_owner_user_name�_parameters�_pool_id�_private_endpoint_dns_zones� _private_endpoint_max_host_count�_private_endpoint_nsg_ids�_private_endpoint_id�_private_endpoint_subnet_id�_run_duration_in_milliseconds�_spark_version� _time_created� _time_updated�_total_o_cpu�_type�_warehouse_bucket_uri�_max_duration_in_minutes�_idle_timeout_in_minutes)�self�kwargs� rr �</usr/lib/python3.9/site-packages/oci/data_flow/models/run.py�__init__N s >�0�/zRun.__init__c C s | j S )a Gets the archive_uri of this Run. A comma separated list of one or more archive files as Oracle Cloud Infrastructure URIs. For example, ``oci://path/to/a.zip,oci://path/to/b.zip``. An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution of a Python, Java, or Scala application. See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. :return: The archive_uri of this Run. :rtype: str �rD �rp rr rr rs r � s zRun.archive_uric C s || _ dS )a( Sets the archive_uri of this Run. A comma separated list of one or more archive files as Oracle Cloud Infrastructure URIs. For example, ``oci://path/to/a.zip,oci://path/to/b.zip``. An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution of a Python, Java, or Scala application. See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. :param archive_uri: The archive_uri of this Run. :type: str Nru )rp r rr rr rs r � s c C s | j S )a$ Gets the arguments of this Run. The arguments passed to the running application as command line arguments. An argument is either a plain text or a placeholder. Placeholders are replaced using values from the parameters map. Each placeholder specified must be represented in the parameters map else the request (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as `Service Api Spec`, where `name` is the name of the parameter. Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` If "input_file" has a value of "mydata.xml", then the value above will be translated to `--input mydata.xml --name "John Doe"` :return: The arguments of this Run. :rtype: list[str] �rE rv rr rr rs r � s z Run.argumentsc C s || _ dS )a, Sets the arguments of this Run. The arguments passed to the running application as command line arguments. An argument is either a plain text or a placeholder. Placeholders are replaced using values from the parameters map. Each placeholder specified must be represented in the parameters map else the request (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as `Service Api Spec`, where `name` is the name of the parameter. Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` If "input_file" has a value of "mydata.xml", then the value above will be translated to `--input mydata.xml --name "John Doe"` :param arguments: The arguments of this Run. :type: list[str] Nrw )rp r rr rr rs r � s c C s | j S )z� **[Required]** Gets the application_id of this Run. The application ID. :return: The application_id of this Run. :rtype: str �rF rv rr rr rs r � s zRun.application_idc C s || _ dS )z� Sets the application_id of this Run. The application ID. :param application_id: The application_id of this Run. :type: str Nrx )rp r rr rr rs r � s c C s | j S )z� Gets the application_log_config of this Run. :return: The application_log_config of this Run. :rtype: oci.data_flow.models.ApplicationLogConfig �rG rv rr rr rs r � s zRun.application_log_configc C s || _ dS )z� Sets the application_log_config of this Run. :param application_log_config: The application_log_config of this Run. :type: oci.data_flow.models.ApplicationLogConfig Nry )rp r rr rr rs r � s c C s | j S )z� Gets the class_name of this Run. The class for the application. :return: The class_name of this Run. :rtype: str �rH rv rr rr rs r s zRun.class_namec C s || _ dS )z� Sets the class_name of this Run. The class for the application. :param class_name: The class_name of this Run. :type: str Nrz )rp r rr rr rs r s c C s | j S )z� **[Required]** Gets the compartment_id of this Run. The OCID of a compartment. :return: The compartment_id of this Run. :rtype: str �rI rv rr rr rs r s zRun.compartment_idc C s || _ dS )z� Sets the compartment_id of this Run. The OCID of a compartment. :param compartment_id: The compartment_id of this Run. :type: str Nr{ )rp r rr rr rs r % s c C s | j S )a. Gets the configuration of this Run. The Spark configuration passed to the running process. See https://spark.apache.org/docs/latest/configuration.html#available-properties. Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } Note: Not all Spark properties are permitted to be set. Attempting to set a property that is not allowed to be overwritten will cause a 400 status to be returned. :return: The configuration of this Run. :rtype: dict(str, str) �rJ rv rr rr rs r 1 s zRun.configurationc C s || _ dS )a: Sets the configuration of this Run. The Spark configuration passed to the running process. See https://spark.apache.org/docs/latest/configuration.html#available-properties. Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } Note: Not all Spark properties are permitted to be set. Attempting to set a property that is not allowed to be overwritten will cause a 400 status to be returned. :param configuration: The configuration of this Run. :type: dict(str, str) Nr| )rp r rr rr rs r A s c C s | j S )z� Gets the data_read_in_bytes of this Run. The data read by the run in bytes. :return: The data_read_in_bytes of this Run. :rtype: int �rK rv rr rr rs r Q s zRun.data_read_in_bytesc C s || _ dS )z� Sets the data_read_in_bytes of this Run. The data read by the run in bytes. :param data_read_in_bytes: The data_read_in_bytes of this Run. :type: int Nr} )rp r rr rr rs r ] s c C s | j S )z� Gets the data_written_in_bytes of this Run. The data written by the run in bytes. :return: The data_written_in_bytes of this Run. :rtype: int �rL rv rr rr rs r i s zRun.data_written_in_bytesc C s || _ dS )z� Sets the data_written_in_bytes of this Run. The data written by the run in bytes. :param data_written_in_bytes: The data_written_in_bytes of this Run. :type: int Nr~ )rp r rr rr rs r u s c C s | j S )a� Gets the defined_tags of this Run. Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see `Resource Tags`__. Example: `{"Operations": {"CostCenter": "42"}}` __ https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm :return: The defined_tags of this Run. :rtype: dict(str, dict(str, object)) �rM rv rr rr rs r! � s zRun.defined_tagsc C s || _ dS )a� Sets the defined_tags of this Run. Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see `Resource Tags`__. Example: `{"Operations": {"CostCenter": "42"}}` __ https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm :param defined_tags: The defined_tags of this Run. :type: dict(str, dict(str, object)) Nr )rp r! rr rr rs r! � s c C s | j S )z� Gets the display_name of this Run. A user-friendly name. This name is not necessarily unique. :return: The display_name of this Run. :rtype: str �rN rv rr rr rs r"