feat: add airflow specific config on job spec

raystack · Apr 14, 2022 · 2c15924 · 2c15924
1 parent 0e3ef79
commit 2c15924
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/odpf/optimus/core/v1beta1/job_spec.proto b/odpf/optimus/core/v1beta1/job_spec.proto
@@ -247,6 +247,7 @@ message JobEvent {
 
 message JobMetadata {
   JobSpecMetadataResource resource = 1;
+  JobSpecMetadataAirflow airflow = 2;
 }
 
 message JobSpecMetadataResource {
@@ -259,6 +260,11 @@ message JobSpecMetadataResourceConfig {
   string memory = 2;
 }
 
+message JobSpecMetadataAirflow {
+  string pool = 1;
+  string queue = 2;
+}
+
 message RefreshJobsRequest {
   string project_name = 1;
   repeated string namespace_names = 2;