This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow-client-go.git
The following commit(s) were added to refs/heads/main by this push:
new 94cc2cb dag run api (#16)
94cc2cb is described below
commit 94cc2cbeaefe3a6aafbb07af713dc18b20017582
Author: Ilia Lazebnik <[email protected]>
AuthorDate: Sun Jan 23 22:35:24 2022 +0200
dag run api (#16)
---
airflow/api/openapi.yaml | 2 --
airflow/docs/DAGRunApi.md | 2 +-
airflow/docs/DagRun.md | 9 +++++++--
airflow/model_dag_run.go | 33 ++++++++++++++++++++-------------
4 files changed, 28 insertions(+), 18 deletions(-)
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 @@ components:
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 @@ import (
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*&#58; Field becomes
nullable. *Deprecated since version 2.2.0*&#58; 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*&#58; Field
becomes nullable. | [optional] [readonly]
@@ -37,7 +37,7 @@ Name | Type | Description | Notes
### 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 @@ and a boolean to check if the value has been set.
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 @@ import (
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 @@ type DAGRun struct {
// 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 @@ func (o *DAGRun) UnsetDagRunId() {
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
+}
+
+// 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 sets field value
+// 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 @@ func (o DAGRun) MarshalJSON() ([]byte, error) {
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() {
