dag run api (#16)
diff --git a/airflow/api/openapi.yaml b/airflow/api/openapi.yaml
index 77d7694..2af1e94 100644
--- a/airflow/api/openapi.yaml
+++ b/airflow/api/openapi.yaml
@@ -4330,8 +4330,6 @@
The value of this field can be set only when creating the object. If you try to modify the
field of an existing object, the request fails with an BAD_REQUEST error.
type: object
- required:
- - dag_id
type: object
UpdateDagRunState:
description: |
diff --git a/airflow/docs/DAGRunApi.md b/airflow/docs/DAGRunApi.md
index f775f0d..8cc59b6 100644
--- a/airflow/docs/DAGRunApi.md
+++ b/airflow/docs/DAGRunApi.md
@@ -349,7 +349,7 @@
func main() {
dagId := "dagId_example" // string | The DAG ID.
- dAGRun := *openapiclient.NewDAGRun("DagId_example") // DAGRun |
+ dAGRun := *openapiclient.NewDAGRun() // DAGRun |
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
diff --git a/airflow/docs/DagRun.md b/airflow/docs/DagRun.md
index d97a864..0aa41f2 100644
--- a/airflow/docs/DagRun.md
+++ b/airflow/docs/DagRun.md
@@ -24,7 +24,7 @@
Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**DagRunId** | Pointer to **NullableString** | Run ID. The value of this field can be set only when creating the object. If you try to modify the field of an existing object, the request fails with an BAD_REQUEST error. If not provided, a value will be generated based on execution_date. If the specified dag_run_id is in use, the creation request fails with an ALREADY_EXISTS error. This together with DAG_ID are a unique key. | [optional]
-**DagId** | **string** | | [readonly]
+**DagId** | Pointer to **string** | | [optional] [readonly]
**LogicalDate** | Pointer to **NullableTime** | The logical date (previously called execution date). This is the time or interval covered by this DAG run, according to the DAG definition. The value of this field can be set only when creating the object. If you try to modify the field of an existing object, the request fails with an BAD_REQUEST error. This together with DAG_ID are a unique key. *New in version 2.2.0* | [optional]
**ExecutionDate** | Pointer to **NullableTime** | The execution date. This is the same as logical_date, kept for backwards compatibility. If both this field and logical_date are provided but with different values, the request will fail with an BAD_REQUEST error. *Changed in version 2.2.0*: Field becomes nullable. *Deprecated since version 2.2.0*: Use 'logical_date' instead. | [optional]
**StartDate** | Pointer to **NullableTime** | The start time. The time when DAG run was actually created. *Changed in version 2.1.3*: Field becomes nullable. | [optional] [readonly]
@@ -37,7 +37,7 @@
### NewDAGRun
-`func NewDAGRun(dagId string, ) *DAGRun`
+`func NewDAGRun() *DAGRun`
NewDAGRun instantiates a new DAGRun object
This constructor will assign default values to properties that have it defined,
@@ -106,6 +106,11 @@
SetDagId sets DagId field to given value.
+### HasDagId
+
+`func (o *DAGRun) HasDagId() bool`
+
+HasDagId returns a boolean if a field has been set.
### GetLogicalDate
diff --git a/airflow/model_dag_run.go b/airflow/model_dag_run.go
index 35dd2bd..bdbc8dd 100644
--- a/airflow/model_dag_run.go
+++ b/airflow/model_dag_run.go
@@ -37,7 +37,7 @@
type DAGRun struct {
// Run ID. The value of this field can be set only when creating the object. If you try to modify the field of an existing object, the request fails with an BAD_REQUEST error. If not provided, a value will be generated based on execution_date. If the specified dag_run_id is in use, the creation request fails with an ALREADY_EXISTS error. This together with DAG_ID are a unique key.
DagRunId NullableString `json:"dag_run_id,omitempty"`
- DagId string `json:"dag_id"`
+ DagId *string `json:"dag_id,omitempty"`
// The logical date (previously called execution date). This is the time or interval covered by this DAG run, according to the DAG definition. The value of this field can be set only when creating the object. If you try to modify the field of an existing object, the request fails with an BAD_REQUEST error. This together with DAG_ID are a unique key. *New in version 2.2.0*
LogicalDate NullableTime `json:"logical_date,omitempty"`
// The execution date. This is the same as logical_date, kept for backwards compatibility. If both this field and logical_date are provided but with different values, the request will fail with an BAD_REQUEST error. *Changed in version 2.2.0*: Field becomes nullable. *Deprecated since version 2.2.0*: Use 'logical_date' instead.
@@ -56,9 +56,8 @@
// This constructor will assign default values to properties that have it defined,
// and makes sure properties required by API are set, but the set of arguments
// will change when the set of required properties is changed
-func NewDAGRun(dagId string) *DAGRun {
+func NewDAGRun() *DAGRun {
this := DAGRun{}
- this.DagId = dagId
return &this
}
@@ -112,28 +111,36 @@
o.DagRunId.Unset()
}
-// GetDagId returns the DagId field value
+// GetDagId returns the DagId field value if set, zero value otherwise.
func (o *DAGRun) GetDagId() string {
- if o == nil {
+ if o == nil || o.DagId == nil {
var ret string
return ret
}
-
- return o.DagId
+ return *o.DagId
}
-// GetDagIdOk returns a tuple with the DagId field value
+// GetDagIdOk returns a tuple with the DagId field value if set, nil otherwise
// and a boolean to check if the value has been set.
func (o *DAGRun) GetDagIdOk() (*string, bool) {
- if o == nil {
+ if o == nil || o.DagId == nil {
return nil, false
}
- return &o.DagId, true
+ return o.DagId, true
}
-// SetDagId sets field value
+// HasDagId returns a boolean if a field has been set.
+func (o *DAGRun) HasDagId() bool {
+ if o != nil && o.DagId != nil {
+ return true
+ }
+
+ return false
+}
+
+// SetDagId gets a reference to the given string and assigns it to the DagId field.
func (o *DAGRun) SetDagId(v string) {
- o.DagId = v
+ o.DagId = &v
}
// GetLogicalDate returns the LogicalDate field value if set, zero value otherwise (both if not set or set to explicit null).
@@ -408,7 +415,7 @@
if o.DagRunId.IsSet() {
toSerialize["dag_run_id"] = o.DagRunId.Get()
}
- if true {
+ if o.DagId != nil {
toSerialize["dag_id"] = o.DagId
}
if o.LogicalDate.IsSet() {
