control-service: Add python_version to GraphQL API (#1909)

# Why
As part of the initiative to add support for multiple Python versions,
we need to extend the GraphQL API to return python_version for each
individual execution.

# What
Added job_python_version column to the data_job_execution table and
job_python_version field to all DTOs related to the GraphQL API.

# Test done
Unit tests. IT test will be added later since the feature for adding
support for multiple Python versions is not ready for e2e testing.

Signed-off-by: Miroslav Ivanov miroslavi@vmware.com

---------

Signed-off-by: Miroslav Ivanov miroslavi@vmware.com
Signed-off-by: gorankokin <gorankokin@gmail.com>
Signed-off-by: dependabot[bot] <support@github.com>
Signed-off-by: Yoan Salambashev <ysalambashev@vmware.com>
Signed-off-by: Duygu Hasan [hduygu@vmware.com](mailto:hduygu@vmware.com)
Signed-off-by: Andon Andonov <andonova@vmware.com>
Co-authored-by: github-actions <>
Co-authored-by: Goran Kokinovski <gorankokin@gmail.com>
Co-authored-by: Goran Kokinovski <gkokinovski@vmware.com>
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Yoan Salambashev <36246462+yonitoo@users.noreply.github.com>
Co-authored-by: ivakoleva <ikoleva@vmware.com>
Co-authored-by: Duygu Hasan <87015481+duyguHsnHsn@users.noreply.github.com>
Co-authored-by: Andy <87700128+doks5@users.noreply.github.com>
Co-authored-by: a_git_a <agita.jaunzeme@gmail.com>
Co-authored-by: Antoni Ivanov <aivanov@vmware.com>

Author: 10 people

projects/control-service/projects/pipelines_control_service/src/main/java/com/vmware/taurus/datajobs/ToApiModelConverter.java

@@ -166,6 +166,7 @@ public static V2DataJobDeployment toV2DataJobDeployment(
     v2DataJobDeployment.setId(jobDeploymentStatus.getCronJobName());
     v2DataJobDeployment.setEnabled(jobDeploymentStatus.getEnabled());
     v2DataJobDeployment.setJobVersion(jobDeploymentStatus.getGitCommitSha());
+    v2DataJobDeployment.setJobPythonVersion(jobDeploymentStatus.getPythonVersion());
     v2DataJobDeployment.setMode(DataJobMode.fromValue(jobDeploymentStatus.getMode()));
     v2DataJobDeployment.setResources(jobDeploymentStatus.getResources());
     v2DataJobDeployment.setLastDeployedBy(jobDeploymentStatus.getLastDeployedBy());

projects/control-service/projects/pipelines_control_service/src/main/java/com/vmware/taurus/service/graphql/model/V2DataJobDeployment.java

@@ -19,6 +19,7 @@ public class V2DataJobDeployment {
   private String id;
   private String vdkVersion;
   private String jobVersion;
+  private String jobPythonVersion;
   private DataJobMode mode;
   private Boolean enabled = true;
   private DataJobContacts contacts;

projects/control-service/projects/pipelines_control_service/src/main/resources/schema.graphqls

@@ -76,6 +76,7 @@ type DataJobExecutionDeployment {
   enabled: Boolean
   contacts: DataJobContacts
   jobVersion: String
+  jobPythonVersion: String
   deployedDate: String
   deployedBy: String
   mode: String
@@ -104,6 +105,7 @@ type DataJobDeployment {
     enabled: Boolean
     contacts: DataJobContacts
     jobVersion: String
+    jobPythonVersion: String
     lastDeployedDate: String
     lastDeployedBy: String
     mode: String

projects/control-service/projects/pipelines_control_service/src/test/java/com/vmware/taurus/RepositoryUtil.java

@@ -145,6 +145,7 @@ public static DataJobExecution createDataJobExecution(
             .lastDeployedBy("test_user")
             .lastDeployedDate(getTimeAccurateToMicroSecond())
             .jobVersion("test_version")
+            .jobPythonVersion("3.11")
             .jobSchedule("*/5 * * * *")
             .opId("test_op_id")
             .vdkVersion("test_vdk_version")

projects/control-service/projects/pipelines_control_service/src/test/java/com/vmware/taurus/datajobs/webhook/ToApiModelConverterJobExecutionTest.java

@@ -43,6 +43,7 @@ public void setUp() {
     dataJobDeployment.enabled(true);
     dataJobDeployment.setDeployedBy("test-user");
     dataJobDeployment.setDeployedDate(OffsetDateTime.MAX);
+    dataJobDeployment.pythonVersion("3.11");
 
     expected = new DataJobExecution();
     expected.setDeployment(dataJobDeployment);
@@ -75,6 +76,7 @@ public void setUp() {
     toConvert.setResourcesCpuRequest(1.4f);
     toConvert.setResourcesMemoryRequest(100);
     toConvert.setResourcesMemoryLimit(150);
+    toConvert.setJobPythonVersion("3.11");
   }
 
   @Test

projects/control-service/projects/pipelines_control_service/src/test/java/com/vmware/taurus/service/JobExecutionRepositoryIT.java

@@ -164,18 +164,6 @@ public void testFindDataJobExecutionsByDataJobName_existingDataJobExecution_shou
     Assertions.assertTrue(actualJobExecutions.isEmpty());
   }
 
-  @Test
-  public void
-      testFindDataJobExecutionsByDataJobName_existingDataJobExecution_shouldReturnResult2() {
-    DataJob actualDataJob = RepositoryUtil.createDataJob(jobsRepository);
-
-    String executionId = "test-execution-id";
-    ExecutionStatus executionStatus = ExecutionStatus.RUNNING;
-    DataJobExecution expectedJobExecution =
-        RepositoryUtil.createDataJobExecution(
-            jobExecutionRepository, executionId, actualDataJob, executionStatus);
-  }
-
   @Test
   void testFindFirstByDataJobNameOrderByStartTimeDesc_withNoExecutions_shouldReturnEmpty() {
     DataJob dataJob = RepositoryUtil.createDataJob(jobsRepository);