sdk/org.apache.airflow.sdk/DagRun

DagRun

data class DagRun(val dagId: String, val runId: String, val logicalDate: OffsetDateTime?, val dataIntervalStart: OffsetDateTime?, val dataIntervalEnd: OffsetDateTime?, val runAfter: OffsetDateTime?, val runType: DagRunType?, val conf: Map<String, Any?>)

Identifies the Dag run that the current task instance belongs to.

Constructors

constructor(dagId: String, runId: String, logicalDate: OffsetDateTime?, dataIntervalStart: OffsetDateTime?, dataIntervalEnd: OffsetDateTime?, runAfter: OffsetDateTime?, runType: DagRunType?, conf: Map<String, Any?>)

Properties

val conf: Map<String, Any?>

The configuration for this run.

val dagId: String

ID of the Dag being run.

dataIntervalEnd

val dataIntervalEnd: OffsetDateTime?

End of the data interval.

dataIntervalStart

val dataIntervalStart: OffsetDateTime?

Start of the data interval.

val logicalDate: OffsetDateTime?

A date-time that logically identifies the current Dag run.

val runAfter: OffsetDateTime?

A date-time tells the scheduler when the Dag run can be scheduled.

val runId: String

Unique identifier for this Dag run.

val runType: DagRunType?

How the run was created.