fix: add instance_type prefix in airflow lib (#136)

arinda-arif · web-flow · commit 0a8d332ea1d9 · 2022-01-13T15:14:25.000+07:00
diff --git a/ext/scheduler/airflow/resources/__lib.py b/ext/scheduler/airflow/resources/__lib.py
@@ -266,7 +266,7 @@ def get_job_metadata(self, execution_date, project, job) -> dict:
                                                                                             job_name=job)
         request_data = {
             "scheduledAt": execution_date,
-            "instance_type": "TASK",
+            "instance_type": "TYPE_TASK",
             "instance_name": "none"
         }
         response = requests.post(url, data=json.dumps(request_data))
diff --git a/ext/scheduler/airflow2/resources/__lib.py b/ext/scheduler/airflow2/resources/__lib.py
@@ -264,7 +264,7 @@ def get_job_metadata(self, execution_date, project, job) -> dict:
                                                                                             job_name=job)
         request_data = {
             "scheduled_at": execution_date,
-            "instance_type": "TASK",
+            "instance_type": "TYPE_TASK",
             "instance_name": "none"
         }
         response = requests.post(url, data=json.dumps(request_data))

Original file line number	Diff line number	Diff line change
`@@ -266,7 +266,7 @@ def get_job_metadata(self, execution_date, project, job) -> dict:`
`266`	`266`	`job_name=job)`
`267`	`267`	`request_data = {`
`268`	`268`	`"scheduledAt": execution_date,`
`269`		`- "instance_type": "TASK",`
	`269`	`+ "instance_type": "TYPE_TASK",`
`270`	`270`	`"instance_name": "none"`
`271`	`271`	`}`
`272`	`272`	`response = requests.post(url, data=json.dumps(request_data))`
Original file line number	Diff line number	Diff line change
`@@ -264,7 +264,7 @@ def get_job_metadata(self, execution_date, project, job) -> dict:`
`264`	`264`	`job_name=job)`
`265`	`265`	`request_data = {`
`266`	`266`	`"scheduled_at": execution_date,`
`267`		`- "instance_type": "TASK",`
	`267`	`+ "instance_type": "TYPE_TASK",`
`268`	`268`	`"instance_name": "none"`
`269`	`269`	`}`
`270`	`270`	`response = requests.post(url, data=json.dumps(request_data))`