Skip to main content

okustera_workflow_dag (Data Source)

The okustera_workflow_dag data source queries metadata, schedules, owners, and recent execution run states for a specific DAG within the tenant's Apache Airflow PaaS environment.

Example Usage​

data "okustera_workflow_dag" "etl" {
  dag_id = "omc_healthcheck_etl"
}

output "etl_schedule" {
  value = data.okustera_workflow_dag.etl.schedule_interval
}

output "etl_is_paused" {
  value = data.okustera_workflow_dag.etl.is_paused
}

output "etl_tags" {
  value = data.okustera_workflow_dag.etl.tags
}

Schema​

Required​

  • dag_id (String) Unique DAG identifier.

Read-Only​

  • description (String) Human-readable description parsed from DAG definition.
  • fileloc (String) Storage path inside the Airflow scheduler container.
  • id (String) Constant identifier for this DAG record.
  • is_active (Boolean) Whether the DAG is recognized as active by Airflow.
  • is_paused (Boolean) Whether the DAG scheduler is currently paused.
  • last_parsed_time (String) Timestamp when Airflow last parsed the DAG definition.
  • last_run_start_date (String) Start timestamp of the most recent execution run.
  • last_run_state (String) State of the most recent execution run.
  • next_dagrun (String) Estimated timestamp for the next automated execution run.
  • owners (List of String) List of owner names associated with the workflow.
  • schedule_interval (String) Schedule interval expression (cron or preset like @daily).
  • tags (List of String) List of organizational and categorizing tags.
  • timetable_description (String) Human-readable timetable schedule description.