Add a way to pass in orchestrator option when calling FTL

Test: usage in androidx.dev

Author: liutikas

AndroidXCI/lib/src/main/kotlin/dev/androidx/ci/testRunner/FirebaseTestLabController.kt

@@ -21,6 +21,7 @@ import dev.androidx.ci.firebase.FirebaseTestLabApi
 import dev.androidx.ci.firebase.dto.EnvironmentType
 import dev.androidx.ci.generated.ftl.AndroidDevice
 import dev.androidx.ci.generated.ftl.AndroidDeviceList
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.ClientInfo
 import dev.androidx.ci.generated.ftl.EnvironmentMatrix
 import dev.androidx.ci.generated.ftl.ShardingOption
@@ -112,7 +113,8 @@ internal class FirebaseTestLabController(
         cachedTestMatrixFilter: CachedTestMatrixFilter,
         testTargets: List<String>? = null,
         flakyTestAttempts: Int = 2,
-        testTimeoutSeconds: Int = 2700
+        testTimeoutSeconds: Int = 2700,
+        orchestratorOption: OrchestratorOption = OrchestratorOption.DO_NOT_USE_ORCHESTRATOR,
     ): List<TestMatrix> {
         val devices = (devicePicker ?: defaultDevicePicker).pickDevices()
         logger.info {
@@ -131,7 +133,8 @@ internal class FirebaseTestLabController(
                 cachedTestMatrixFilter = cachedTestMatrixFilter,
                 testTargets = testTargets,
                 flakyTestAttempts = flakyTestAttempts,
-                testTimeoutSeconds = testTimeoutSeconds
+                testTimeoutSeconds = testTimeoutSeconds,
+                orchestratorOption = orchestratorOption,
             )
         }
     }

AndroidXCI/lib/src/main/kotlin/dev/androidx/ci/testRunner/TestMatrixStore.kt

@@ -22,6 +22,7 @@ import dev.androidx.ci.firebase.FirebaseTestLabApi
 import dev.androidx.ci.firebase.ToolsResultApi
 import dev.androidx.ci.gcloud.GcsPath
 import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.ClientInfo
 import dev.androidx.ci.generated.ftl.EnvironmentMatrix
 import dev.androidx.ci.generated.ftl.FileReference
@@ -72,7 +73,8 @@ internal class TestMatrixStore(
         cachedTestMatrixFilter: CachedTestMatrixFilter = { true },
         testTargets: List<String>? = null,
         flakyTestAttempts: Int = 2,
-        testTimeoutSeconds: Int = 2700
+        testTimeoutSeconds: Int = 2700,
+        orchestratorOption: OrchestratorOption = OrchestratorOption.DO_NOT_USE_ORCHESTRATOR,
     ): TestMatrix {
 
         val testRunId = TestRun.createId(
@@ -82,7 +84,8 @@ internal class TestMatrixStore(
             sharding = sharding,
             appApk = appApk.apkInfo,
             testApk = testApk.apkInfo,
-            deviceSetup = deviceSetup
+            deviceSetup = deviceSetup,
+            orchestratorOption = orchestratorOption,
         )
         logger.trace {
             "test run id: $testRunId"
@@ -302,7 +305,8 @@ internal class TestMatrixStore(
                     gcsPath = testApk.gcsPath.path
                 ),
                 shardingOption = sharding,
-                testTargets = testTargets
+                testTargets = testTargets,
+                orchestratorOption = deviceSetup?.orchestratorOption
             ),
             testSetup = testSetup
         )

AndroidXCI/lib/src/main/kotlin/dev/androidx/ci/testRunner/TestRunnerService.kt

@@ -9,6 +9,8 @@ import dev.androidx.ci.firebase.ToolsResultApi
 import dev.androidx.ci.gcloud.GcsPath
 import dev.androidx.ci.gcloud.GoogleCloudApi
 import dev.androidx.ci.generated.ftl.AndroidDevice
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.ClientInfo
 import dev.androidx.ci.generated.ftl.ShardingOption
 import dev.androidx.ci.generated.ftl.TestEnvironmentCatalog
@@ -83,7 +85,8 @@ interface TestRunnerService {
         cachedTestMatrixFilter: CachedTestMatrixFilter = { true },
         testTargets: List<String>? = null,
         flakyTestAttempts: Int = 2,
-        testTimeoutSeconds: Int = 2700
+        testTimeoutSeconds: Int = 2700,
+        orchestratorOption: OrchestratorOption = OrchestratorOption.DO_NOT_USE_ORCHESTRATOR,
     ): ScheduleTestsResponse
 
     /**

AndroidXCI/lib/src/main/kotlin/dev/androidx/ci/testRunner/TestRunnerServiceImpl.kt

@@ -22,6 +22,7 @@ import dev.androidx.ci.gcloud.BlobVisitor
 import dev.androidx.ci.gcloud.GcsPath
 import dev.androidx.ci.gcloud.GoogleCloudApi
 import dev.androidx.ci.generated.ftl.AndroidDevice
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.ClientInfo
 import dev.androidx.ci.generated.ftl.ShardingOption
 import dev.androidx.ci.generated.ftl.TestEnvironmentCatalog
@@ -103,7 +104,8 @@ internal class TestRunnerServiceImpl internal constructor(
         cachedTestMatrixFilter: CachedTestMatrixFilter,
         testTargets: List<String>?,
         flakyTestAttempts: Int,
-        testTimeoutSeconds: Int
+        testTimeoutSeconds: Int,
+        orchestratorOption: OrchestratorOption,
     ): TestRunnerService.ScheduleTestsResponse {
         val testMatrices = testLabController.submitTests(
             appApk = appApk ?: apkStore.getPlaceholderApk(),

AndroidXCI/lib/src/main/kotlin/dev/androidx/ci/testRunner/dto/TestRun.kt

@@ -23,6 +23,7 @@ import com.google.cloud.datastore.Key
 import com.squareup.moshi.Moshi
 import com.squareup.moshi.Types
 import dev.androidx.ci.datastore.DatastoreApi
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.ClientInfo
 import dev.androidx.ci.generated.ftl.EnvironmentMatrix
 import dev.androidx.ci.generated.ftl.ShardingOption
@@ -72,7 +73,8 @@ internal class TestRun(
             appApk: ApkInfo,
             testApk: ApkInfo,
             deviceSetup: DeviceSetup?,
-            sharding: ShardingOption?
+            sharding: ShardingOption?,
+            orchestratorOption: OrchestratorOption?,
         ): Id {
             val json = adapter.toJson(
                 mapOf(
@@ -87,6 +89,7 @@ internal class TestRun(
                     "additionalApks" to deviceSetup?.additionalApks?.map {
                         it.gcsPath.path
                     }, // The order we install additional apks is important, so we do not sort here.
+                    "orchestratorOption" to deviceSetup?.orchestratorOption,
                     "directoriesToPull" to deviceSetup?.directoriesToPull?.sorted()
                 )
             )

AndroidXCI/lib/src/main/kotlin/dev/androidx/ci/testRunner/vo/DeviceSetup.kt

@@ -1,5 +1,6 @@
 package dev.androidx.ci.testRunner.vo
 
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.Apk
 import dev.androidx.ci.generated.ftl.EnvironmentVariable
 import dev.androidx.ci.generated.ftl.FileReference
@@ -25,7 +26,9 @@ data class DeviceSetup(
     /**
      * List of instrumentation arguments to be passed into the runner.
      */
-    val instrumentationArguments: List<InstrumentationArgument>? = null
+    val instrumentationArguments: List<InstrumentationArgument>? = null,
+
+    var orchestratorOption: OrchestratorOption = OrchestratorOption.DO_NOT_USE_ORCHESTRATOR
 ) {
     internal fun toTestSetup(): TestSetup {
         return TestSetup(

AndroidXCI/lib/src/test/kotlin/dev/androidx/ci/testRunner/TestMatrixStoreTest.kt

@@ -23,6 +23,7 @@ import dev.androidx.ci.fake.FakeToolsResultApi
 import dev.androidx.ci.gcloud.GcsPath
 import dev.androidx.ci.generated.ftl.AndroidDevice
 import dev.androidx.ci.generated.ftl.AndroidDeviceList
+import dev.androidx.ci.generated.ftl.AndroidInstrumentationTest.OrchestratorOption
 import dev.androidx.ci.generated.ftl.ClientInfo
 import dev.androidx.ci.generated.ftl.ClientInfoDetail
 import dev.androidx.ci.generated.ftl.EnvironmentMatrix
@@ -340,7 +341,8 @@ internal class TestMatrixStoreTest {
             sharding = ShardingOption(),
             appApk = createFakeApk("app.pak").apkInfo,
             testApk = createFakeApk("test.apk").apkInfo,
-            deviceSetup = DeviceSetup()
+            deviceSetup = DeviceSetup(),
+            orchestratorOption = OrchestratorOption.DO_NOT_USE_ORCHESTRATOR,
         )
 
         val resultGcsPath1 = store.createUniqueResultGcsPath(testRunId)