From e33b0c2188e99eb875a16e85d9beb6468eb8deee Mon Sep 17 00:00:00 2001 From: Charles Date: Wed, 24 Mar 2021 18:44:53 -0700 Subject: [PATCH] fix build (#2608) --- .../server/handlers/WorkspacesHandlerTest.java | 1 + .../temporal/TemporalAttemptExecutionTest.java | 14 +++++++++----- build.gradle | 16 ++++++++-------- 3 files changed, 18 insertions(+), 13 deletions(-) diff --git a/airbyte-server/src/test/java/io/airbyte/server/handlers/WorkspacesHandlerTest.java b/airbyte-server/src/test/java/io/airbyte/server/handlers/WorkspacesHandlerTest.java index d3a6fd64044..efa9bc584f6 100644 --- a/airbyte-server/src/test/java/io/airbyte/server/handlers/WorkspacesHandlerTest.java +++ b/airbyte-server/src/test/java/io/airbyte/server/handlers/WorkspacesHandlerTest.java @@ -62,6 +62,7 @@ class WorkspacesHandlerTest { private StandardWorkspace workspace; private WorkspacesHandler workspacesHandler; + @SuppressWarnings("unchecked") @BeforeEach void setUp() { configRepository = mock(ConfigRepository.class); diff --git a/airbyte-workers/src/test/java/io/airbyte/workers/temporal/TemporalAttemptExecutionTest.java b/airbyte-workers/src/test/java/io/airbyte/workers/temporal/TemporalAttemptExecutionTest.java index 5e10bbc299e..ee403ab8515 100644 --- a/airbyte-workers/src/test/java/io/airbyte/workers/temporal/TemporalAttemptExecutionTest.java +++ b/airbyte-workers/src/test/java/io/airbyte/workers/temporal/TemporalAttemptExecutionTest.java @@ -55,7 +55,6 @@ class TemporalAttemptExecutionTest { private CheckedSupplier, Exception> execution; private BiConsumer mdcSetter; - private CheckedConsumer jobRootDirCreator; private TemporalAttemptExecution attemptExecution; @@ -64,20 +63,25 @@ class TemporalAttemptExecutionTest { void setup() throws IOException { final Path workspaceRoot = Files.createTempDirectory(Path.of("/tmp"), "temporal_attempt_execution_test"); jobRoot = workspaceRoot.resolve(JOB_ID).resolve(String.valueOf(ATTEMPT_ID)); - jobRoot = workspaceRoot.resolve(String.valueOf(JOB_ID)).resolve(String.valueOf(ATTEMPT_ID)); execution = mock(CheckedSupplier.class); mdcSetter = mock(BiConsumer.class); - jobRootDirCreator = Files::createDirectories; + final CheckedConsumer jobRootDirCreator = Files::createDirectories; - attemptExecution = new TemporalAttemptExecution<>(workspaceRoot, JOB_RUN_CONFIG, execution, () -> "", mdcSetter, jobRootDirCreator, + attemptExecution = new TemporalAttemptExecution<>( + workspaceRoot, + JOB_RUN_CONFIG, execution, + () -> "", + mdcSetter, + jobRootDirCreator, mock(CancellationHandler.class), () -> "workflow_id"); } + @SuppressWarnings("unchecked") @Test void testSuccessfulSupplierRun() throws Exception { final String expected = "louis XVI"; - Worker worker = mock(Worker.class); + final Worker worker = mock(Worker.class); when(worker.run(any(), any())).thenReturn(expected); when(execution.get()).thenAnswer((Answer>) invocation -> worker); diff --git a/build.gradle b/build.gradle index 45da47674f0..03eb84ce409 100644 --- a/build.gradle +++ b/build.gradle @@ -99,16 +99,16 @@ allprojects { afterEvaluate { project -> def composeDeps = [ - "airbyte-config:init", - "airbyte-db", - "airbyte-migration", - "airbyte-scheduler:app", - "airbyte-server", - "airbyte-webapp", + ":airbyte-config:init", + ":airbyte-db", + ":airbyte-migration", + ":airbyte-scheduler:app", + ":airbyte-server", + ":airbyte-webapp", ].toSet().asImmutable() - if (project.name in composeDeps) { - composeBuild.dependsOn(project.tasks.assemble) + if (project.getPath() in composeDeps) { + composeBuild.dependsOn(project.getPath() + ':assemble') } } }