Executions

pydantic model openapi_client.models.executions.Executions

One dataflow run in dataflowExecutions (JDBC Bulkload, Advanced Load, or ArcGIS). Fields vary by type and whether the list used Bulkload pagination projection.

Fields:

• cdc_sync_to_s3 (str | None)

• current_retry (int | None)

• data_ingestion_error_log_url (str | None)

• data_ingestion_job_run_id (str | None)

• data_ingestion_output_log_url (str | None)

• dataflow_id (str | None)

• datasource_id (str | None)

• end_time (str | None)

• estimated_cost (float | int | None)

• execution_arn (str | None)

• execution_id (str | None)

• full_load_schedule (str | None)

• insights_metrics (List[Dict[str, Any]] | None)

• last_modified_by (str | None)

• last_modified_time (str | None)

• message (str | None)

• metadata_ingestion_error_log_url (str | None)

• metadata_ingestion_job_run_id (str | None)

• metadata_ingestion_output_log_url (str | None)

• reload_tables (List[openapi_client.models.dataflow_reload_table_entry.DataflowReloadTableEntry] | None)

• run_status (str | None)

• run_type (str | None)

• schedule_execution_id (str | None)

• schedule_id (str | None)

• start_time (str)

• table_mappings (Dict[str, Any] | None)

• table_stats (List[openapi_client.models.dataflow_task_stats_entry.DataflowTaskStatsEntry] | None)

field execution_id: Optional[StrictStr] = None (alias 'ExecutionId')

Unique run ID. Present for ArcGIS. Not set on JDBC Bulkload create.

field start_time: StrictStr [Required] (alias 'StartTime')

When the execution started (DynamoDB sort key with DataflowId).

Constraints:

• strict = True

field end_time: Optional[StrictStr] = None (alias 'EndTime')

When the execution ended, when available.

field run_status: Optional[StrictStr] = None (alias 'RunStatus')

Current run state for JDBC Bulkload, Advanced Load, and ArcGIS (e.g. completed, failed, running).

field current_retry: Optional[StrictInt] = None (alias 'CurrentRetry')

Retry count. Included in JDBC Bulkload paginated projection; may be present on full Bulkload run items.

field table_stats: Optional[List[DataflowTaskStatsEntry]] = None (alias 'TableStats')

Per-table stats on full JDBC run items. Omitted from Bulkload paginated list projection.

field insights_metrics: Optional[List[Dict[str, Any]]] = None (alias 'InsightsMetrics')

Insight metrics on full JDBC run items. Omitted from Bulkload paginated list projection.

field table_mappings: Optional[Dict[str, Any]] = None (alias 'TableMappings')

Selective-reload table mappings on full JDBC Bulkload runs. Omitted from paginated list projection.

field execution_arn: Optional[StrictStr] = None (alias 'ExecutionArn')

Step Function execution ARN when present (e.g. ArcGIS).

field dataflow_id: Optional[StrictStr] = None (alias 'DataflowId')

ID of the dataflow for this execution.

field datasource_id: Optional[StrictStr] = None (alias 'DatasourceId')

Parent datasource ID when stored on the run (e.g. ArcGIS).

field message: Optional[StrictStr] = None (alias 'Message')

Status or error message for the execution.

field last_modified_by: Optional[StrictStr] = None (alias 'LastModifiedBy')

User who last updated the execution.

field last_modified_time: Optional[StrictStr] = None (alias 'LastModifiedTime')

When the execution was last updated (when present).

field estimated_cost: Optional[Union[StrictFloat, StrictInt]] = None (alias 'EstimatedCost')

Estimated cost for ArcGIS runs. List handler may backfill for completed/failed runs missing this field.

field schedule_id: Optional[StrictStr] = None (alias 'ScheduleId')

Schedule that triggered this run, when applicable.

field schedule_execution_id: Optional[StrictStr] = None (alias 'ScheduleExecutionId')

Schedule run ID that triggered this execution, when applicable.

field full_load_schedule: Optional[StrictStr] = None (alias 'fullLoadSchedule')

ArcGIS flag that the run was started by a full-load schedule.

field cdc_sync_to_s3: Optional[StrictStr] = None (alias 'cdcSyncToS3')

ArcGIS flag that the run was started by a CDC sync-to-S3 schedule.

field metadata_ingestion_job_run_id: Optional[StrictStr] = None (alias 'MetadataIngestionJobRunId')

ArcGIS Glue job run ID for metadata ingestion.

field data_ingestion_job_run_id: Optional[StrictStr] = None (alias 'DataIngestionJobRunId')

ArcGIS Glue job run ID for data ingestion.

field metadata_ingestion_output_log_url: Optional[StrictStr] = None (alias 'MetadataIngestionOutputLogURL')

Presigned URL for metadata ingestion output logs. Added on GET …/executions/{execution_id} when MetadataIngestionJobRunId is set and the log file exists.

field metadata_ingestion_error_log_url: Optional[StrictStr] = None (alias 'MetadataIngestionErrorLogURL')

Presigned URL for metadata ingestion error logs. Added on GET …/executions/{execution_id} when the error log file exists.

field data_ingestion_output_log_url: Optional[StrictStr] = None (alias 'DataIngestionOutputLogURL')

Presigned URL for data ingestion output logs. Added on GET …/executions/{execution_id} when DataIngestionJobRunId is set and the log file exists.

field data_ingestion_error_log_url: Optional[StrictStr] = None (alias 'DataIngestionErrorLogURL')

Presigned URL for data ingestion error logs. Added on GET …/executions/{execution_id} when the error log file exists.

field run_type: Optional[StrictStr] = None (alias 'RunType')

Kind of run, e.g. PartialReload for Advanced Load selective reload.

field reload_tables: Optional[List[DataflowReloadTableEntry]] = None (alias 'ReloadTables')

Selective-reload tables on JDBC Bulkload/Advanced full run items. Omitted from Bulkload paginated projection.

to_str()

Returns the string representation of the model using alias

Return type:

str

to_json()

Returns the JSON representation of the model using alias

Return type:

str

classmethod from_json(json_str)

Create an instance of Executions from a JSON string

Return type:

Optional[Self]

to_dict()

Return the dictionary representation of the model using alias.

This has the following differences from calling pydantic’s self.model_dump(by_alias=True):

• None is only added to the output dict for nullable fields that were set at model initialization. Other fields with value None are ignored.

Return type:

Dict[str, Any]

classmethod from_dict(obj)

Create an instance of Executions from a dict

Return type:

Optional[Self]