keboola.flow is orchestration container job type

Author: ondrajodas

src/JobFactory.php

@@ -12,6 +12,9 @@
 abstract class JobFactory
 {
     public const ORCHESTRATOR_COMPONENT = 'keboola.orchestrator';
+
+    public const FLOW_COMPONENT = 'keboola.flow';
+
     public const PROTECTED_DEFAULT_BRANCH_FEATURE = 'protected-default-branch';
 
     /**

src/JobFactory/JobRuntimeResolver.php

@@ -275,7 +275,9 @@ private function resolveJobType(array $jobData): JobType
         if ((intval($jobData['parallelism']) > 0) || $jobData['parallelism'] === JobInterface::PARALLELISM_INFINITY) {
             return JobType::ROW_CONTAINER;
         } else {
-            if ($jobData['componentId'] === JobFactory::ORCHESTRATOR_COMPONENT) {
+            if ($jobData['componentId'] === JobFactory::FLOW_COMPONENT) {
+                return JobType::ORCHESTRATION_CONTAINER;
+            } elseif ($jobData['componentId'] === JobFactory::ORCHESTRATOR_COMPONENT) {
                 if (isset($jobData['configData']['phaseId']) && (string) ($jobData['configData']['phaseId']) !== '') {
                     return JobType::PHASE_CONTAINER;
                 } else {

src/Orchestration/OrchestrationJobMatcher.php

@@ -92,7 +92,7 @@ private function validateInputs(JobInterface $job, array $configuration): void
         /* since the matcher accepts a jobId, we need to check that it is a sort of sensible input -
             the main use case is root orchestration job, but it seems that a phaseContainer might be
             equally valid input. */
-        if ($job->getComponentId() !== JobFactory::ORCHESTRATOR_COMPONENT) {
+        if (!in_array($job->getComponentId(), [JobFactory::ORCHESTRATOR_COMPONENT, JobFactory::FLOW_COMPONENT], true)) {
             throw new OrchestrationJobMatcherValidationException(sprintf(
                 'Job "%s" is not an orchestration job.',
                 $job->getId(),

tests/JobFactory/JobRuntimeResolverTest.php

@@ -69,6 +69,12 @@ public function resolveDefaultBackendContextData(): Generator
             JobType::ORCHESTRATION_CONTAINER,
             null,
         ];
+        yield 'flow job' => [
+            JobFactory::FLOW_COMPONENT,
+            [],
+            JobType::ORCHESTRATION_CONTAINER,
+            null,
+        ];
     }
 
     /**