Skip to content

Commit 96499ec

Browse files
zachliuzachliu
committed
dag_id is a damn string
1 parent 6ca5bb0 commit 96499ec

File tree

15 files changed

+89
-89
lines changed

15 files changed

+89
-89
lines changed

‎README.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ Apache Airflow management API.
44
This Python package is automatically generated by the [OpenAPI Generator](https://openapi-generator.tech) project based on [the specs](https://github.com/zachliu/airflow-openapi-specs):
55

66
- API version: 1.0.0
7-
- Package version: 0.1.5
7+
- Package version: 0.1.6
88
- Build package: org.openapitools.codegen.languages.PythonClientCodegen
99
For more information, please visit [https://github.com/zachliu](https://github.com/zachliu)
1010

‎airflow_python_sdk/__init__.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
"""
1212

1313

14-
__version__ = "0.1.5"
14+
__version__ = "0.1.6"
1515

1616
# import ApiClient
1717
from airflow_python_sdk.api_client import ApiClient

‎airflow_python_sdk/api/dag_api.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ def __clear_task_instances(
6161
>>> result = thread.get()
6262
6363
Args:
64-
dag_id (int): The DAG ID.
64+
dag_id (str): The DAG ID.
6565
clear_task_instance (ClearTaskInstance): Parameters of action
6666
6767
Keyword Args:
@@ -149,7 +149,7 @@ def __clear_task_instances(
149149
},
150150
'openapi_types': {
151151
'dag_id':
152-
(int,),
152+
(str,),
153153
'clear_task_instance':
154154
(ClearTaskInstance,),
155155
},
@@ -190,7 +190,7 @@ def __get_dag(
190190
>>> result = thread.get()
191191
192192
Args:
193-
dag_id (int): The DAG ID.
193+
dag_id (str): The DAG ID.
194194
195195
Keyword Args:
196196
_return_http_data_only (bool): response data without head status
@@ -273,7 +273,7 @@ def __get_dag(
273273
},
274274
'openapi_types': {
275275
'dag_id':
276-
(int,),
276+
(str,),
277277
},
278278
'attribute_map': {
279279
'dag_id': 'dag_id',
@@ -426,7 +426,7 @@ def __get_dag_structure(
426426
>>> result = thread.get()
427427
428428
Args:
429-
dag_id (int): The DAG ID.
429+
dag_id (str): The DAG ID.
430430
431431
Keyword Args:
432432
_return_http_data_only (bool): response data without head status
@@ -509,7 +509,7 @@ def __get_dag_structure(
509509
},
510510
'openapi_types': {
511511
'dag_id':
512-
(int,),
512+
(str,),
513513
},
514514
'attribute_map': {
515515
'dag_id': 'dag_id',
@@ -673,7 +673,7 @@ def __get_task(
673673
>>> result = thread.get()
674674
675675
Args:
676-
dag_id (int): The DAG ID.
676+
dag_id (str): The DAG ID.
677677
task_id (int): The Task ID.
678678
679679
Keyword Args:
@@ -761,7 +761,7 @@ def __get_task(
761761
},
762762
'openapi_types': {
763763
'dag_id':
764-
(int,),
764+
(str,),
765765
'task_id':
766766
(int,),
767767
},
@@ -800,7 +800,7 @@ def __get_tasks(
800800
>>> result = thread.get()
801801
802802
Args:
803-
dag_id (int): The DAG ID.
803+
dag_id (str): The DAG ID.
804804
805805
Keyword Args:
806806
_return_http_data_only (bool): response data without head status
@@ -883,7 +883,7 @@ def __get_tasks(
883883
},
884884
'openapi_types': {
885885
'dag_id':
886-
(int,),
886+
(str,),
887887
},
888888
'attribute_map': {
889889
'dag_id': 'dag_id',
@@ -918,7 +918,7 @@ def __update_dag(
918918
>>> result = thread.get()
919919
920920
Args:
921-
dag_id (int): The DAG ID.
921+
dag_id (str): The DAG ID.
922922
923923
Keyword Args:
924924
_return_http_data_only (bool): response data without head status
@@ -1001,7 +1001,7 @@ def __update_dag(
10011001
},
10021002
'openapi_types': {
10031003
'dag_id':
1004-
(int,),
1004+
(str,),
10051005
},
10061006
'attribute_map': {
10071007
'dag_id': 'dag_id',

‎airflow_python_sdk/api/dag_run_api.py‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ def __delete_dag_run(
5454
>>> result = thread.get()
5555
5656
Args:
57-
dag_id (int): The DAG ID.
57+
dag_id (str): The DAG ID.
5858
dag_run_id (int): The DAG Run ID.
5959
6060
Keyword Args:
@@ -142,7 +142,7 @@ def __delete_dag_run(
142142
},
143143
'openapi_types': {
144144
'dag_id':
145-
(int,),
145+
(str,),
146146
'dag_run_id':
147147
(int,),
148148
},
@@ -182,7 +182,7 @@ def __get_dag_run(
182182
>>> result = thread.get()
183183
184184
Args:
185-
dag_id (int): The DAG ID.
185+
dag_id (str): The DAG ID.
186186
dag_run_id (int): The DAG Run ID.
187187
188188
Keyword Args:
@@ -270,7 +270,7 @@ def __get_dag_run(
270270
},
271271
'openapi_types': {
272272
'dag_id':
273-
(int,),
273+
(str,),
274274
'dag_run_id':
275275
(int,),
276276
},
@@ -310,7 +310,7 @@ def __get_dag_runs(
310310
>>> result = thread.get()
311311
312312
Args:
313-
dag_id (int): The DAG ID.
313+
dag_id (str): The DAG ID.
314314
315315
Keyword Args:
316316
limit (int): The numbers of items to return.. [optional] if omitted the server will use the default value of 100
@@ -407,7 +407,7 @@ def __get_dag_runs(
407407
},
408408
'openapi_types': {
409409
'dag_id':
410-
(int,),
410+
(str,),
411411
'limit':
412412
(int,),
413413
'offset':
@@ -452,7 +452,7 @@ def __update_dag_run(
452452
>>> result = thread.get()
453453
454454
Args:
455-
dag_id (int): The DAG ID.
455+
dag_id (str): The DAG ID.
456456
dag_run_id (int): The DAG Run ID.
457457
dag_run (DAGRun):
458458
@@ -547,7 +547,7 @@ def __update_dag_run(
547547
},
548548
'openapi_types': {
549549
'dag_id':
550-
(int,),
550+
(str,),
551551
'dag_run_id':
552552
(int,),
553553
'dag_run':

‎airflow_python_sdk/api/pool_api.py‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -539,7 +539,7 @@ def __get_task_instances(
539539
>>> result = thread.get()
540540
541541
Args:
542-
dag_id (int): The DAG ID.
542+
dag_id (str): The DAG ID.
543543
544544
Keyword Args:
545545
limit (int): The numbers of items to return.. [optional] if omitted the server will use the default value of 100
@@ -636,7 +636,7 @@ def __get_task_instances(
636636
},
637637
'openapi_types': {
638638
'dag_id':
639-
(int,),
639+
(str,),
640640
'limit':
641641
(int,),
642642
'offset':

‎airflow_python_sdk/api/task_instance_api.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ def __delete_task_instance(
5656
>>> result = thread.get()
5757
5858
Args:
59-
dag_id (int): The DAG ID.
59+
dag_id (str): The DAG ID.
6060
task_id (int): The Task ID.
6161
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
6262
@@ -149,7 +149,7 @@ def __delete_task_instance(
149149
},
150150
'openapi_types': {
151151
'dag_id':
152-
(int,),
152+
(str,),
153153
'task_id':
154154
(int,),
155155
'execution_date':
@@ -194,7 +194,7 @@ def __get_extra_links(
194194
>>> result = thread.get()
195195
196196
Args:
197-
dag_id (int): The DAG ID.
197+
dag_id (str): The DAG ID.
198198
task_id (int): The Task ID.
199199
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
200200
@@ -287,7 +287,7 @@ def __get_extra_links(
287287
},
288288
'openapi_types': {
289289
'dag_id':
290-
(int,),
290+
(str,),
291291
'task_id':
292292
(int,),
293293
'execution_date':
@@ -333,7 +333,7 @@ def __get_logs(
333333
>>> result = thread.get()
334334
335335
Args:
336-
dag_id (int): The DAG ID.
336+
dag_id (str): The DAG ID.
337337
task_id (int): The Task ID.
338338
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
339339
task_try_number (int): The Task Try Number.
@@ -435,7 +435,7 @@ def __get_logs(
435435
},
436436
'openapi_types': {
437437
'dag_id':
438-
(int,),
438+
(str,),
439439
'task_id':
440440
(int,),
441441
'execution_date':
@@ -493,7 +493,7 @@ def __get_task_instance(
493493
>>> result = thread.get()
494494
495495
Args:
496-
dag_id (int): The DAG ID.
496+
dag_id (str): The DAG ID.
497497
task_id (int): The Task ID.
498498
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
499499
@@ -586,7 +586,7 @@ def __get_task_instance(
586586
},
587587
'openapi_types': {
588588
'dag_id':
589-
(int,),
589+
(str,),
590590
'task_id':
591591
(int,),
592592
'execution_date':
@@ -632,7 +632,7 @@ def __update_task_instance(
632632
>>> result = thread.get()
633633
634634
Args:
635-
dag_id (int): The DAG ID.
635+
dag_id (str): The DAG ID.
636636
task_id (int): The Task ID.
637637
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
638638
task_instance (TaskInstance):
@@ -732,7 +732,7 @@ def __update_task_instance(
732732
},
733733
'openapi_types': {
734734
'dag_id':
735-
(int,),
735+
(str,),
736736
'task_id':
737737
(int,),
738738
'execution_date':

‎airflow_python_sdk/api/x_com_api.py‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ def __delete_x_com_value(
5656
>>> result = thread.get()
5757
5858
Args:
59-
dag_id (int): The DAG ID.
59+
dag_id (str): The DAG ID.
6060
task_id (int): The Task ID.
6161
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
6262
key (str): The XCom Key.
@@ -154,7 +154,7 @@ def __delete_x_com_value(
154154
},
155155
'openapi_types': {
156156
'dag_id':
157-
(int,),
157+
(str,),
158158
'task_id':
159159
(int,),
160160
'execution_date':
@@ -204,7 +204,7 @@ def __get_x_com_value(
204204
>>> result = thread.get()
205205
206206
Args:
207-
dag_id (int): The DAG ID.
207+
dag_id (str): The DAG ID.
208208
task_id (int): The Task ID.
209209
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
210210
key (str): The XCom Key.
@@ -302,7 +302,7 @@ def __get_x_com_value(
302302
},
303303
'openapi_types': {
304304
'dag_id':
305-
(int,),
305+
(str,),
306306
'task_id':
307307
(int,),
308308
'execution_date':
@@ -352,7 +352,7 @@ def __get_x_com_values(
352352
>>> result = thread.get()
353353
354354
Args:
355-
dag_id (int): The DAG ID.
355+
dag_id (str): The DAG ID.
356356
task_id (int): The Task ID.
357357
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
358358
@@ -459,7 +459,7 @@ def __get_x_com_values(
459459
},
460460
'openapi_types': {
461461
'dag_id':
462-
(int,),
462+
(str,),
463463
'task_id':
464464
(int,),
465465
'execution_date':
@@ -514,7 +514,7 @@ def __update_x_com_value(
514514
>>> result = thread.get()
515515
516516
Args:
517-
dag_id (int): The DAG ID.
517+
dag_id (str): The DAG ID.
518518
task_id (int): The Task ID.
519519
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
520520
key (str): The XCom Key.
@@ -619,7 +619,7 @@ def __update_x_com_value(
619619
},
620620
'openapi_types': {
621621
'dag_id':
622-
(int,),
622+
(str,),
623623
'task_id':
624624
(int,),
625625
'execution_date':
@@ -679,7 +679,7 @@ def __update_x_com_values(
679679
>>> result = thread.get()
680680
681681
Args:
682-
dag_id (int): The DAG ID.
682+
dag_id (str): The DAG ID.
683683
task_id (int): The Task ID.
684684
execution_date (datetime): The date-time notation as defined by [RFC 3339, section 5.6](https://tools.ietf.org/html/rfc3339#section-5.6), E.G. `2017-07-21T17:32:28Z`
685685
x_com (XCom):
@@ -777,7 +777,7 @@ def __update_x_com_values(
777777
},
778778
'openapi_types': {
779779
'dag_id':
780-
(int,),
780+
(str,),
781781
'task_id':
782782
(int,),
783783
'execution_date':

0 commit comments

Comments
 (0)