diff --git a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/AdHocTriggeringIT.java b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/AdHocTriggeringIT.java index e38c818189..9cb655cff9 100644 --- a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/AdHocTriggeringIT.java +++ b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/AdHocTriggeringIT.java @@ -32,12 +32,15 @@ import java.nio.file.Files; import java.util.List; import java.util.Map; + +import org.junit.Ignore; import org.junit.Test; @AutoService(EndToEndTestBase.class) public class AdHocTriggeringIT extends EndToEndTestBase { @Test + @Ignore public void testAdhocTriggeringFlyteWorkflow() throws Exception { // Generate workflow configuration var workflowJson = Json.OBJECT_MAPPER.writeValueAsString(Map.of( diff --git a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/BackfillIT.java b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/BackfillIT.java index a27c3453eb..35b43f2c45 100644 --- a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/BackfillIT.java +++ b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/BackfillIT.java @@ -37,6 +37,8 @@ import java.util.List; import java.util.Map; import java.util.stream.Stream; + +import org.junit.Ignore; import org.junit.Test; @AutoService(EndToEndTestBase.class) @@ -55,6 +57,7 @@ public void testBackfill() throws Exception { } @Test + @Ignore public void testBackfillFlyteWorkflow() throws Exception { // Generate workflow configuration var workflowJson = Json.OBJECT_MAPPER.writeValueAsString(Map.of( diff --git a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/CreateDeleteWorkflowIT.java b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/CreateDeleteWorkflowIT.java index 40c37e7b6b..0ba3545289 100644 --- a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/CreateDeleteWorkflowIT.java +++ b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/CreateDeleteWorkflowIT.java @@ -35,6 +35,8 @@ import java.nio.file.Files; import java.util.List; import java.util.Optional; + +import org.junit.Ignore; import org.junit.Test; @AutoService(EndToEndTestBase.class) @@ -54,6 +56,7 @@ public void testCreateDeleteWorkflow() throws Exception { } @Test + @Ignore public void testCreateDeleteFlyteWorkflow() throws Exception { var workflowConfiguration = WorkflowConfiguration.builder() .id(workflowId1) diff --git a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/ScheduledTriggeringIT.java b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/ScheduledTriggeringIT.java index fced8b9686..5c0dd6fc88 100644 --- a/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/ScheduledTriggeringIT.java +++ b/styx-e2e-test/src/test/java/com/spotify/styx/e2e_tests/ScheduledTriggeringIT.java @@ -33,12 +33,15 @@ import java.time.temporal.ChronoUnit; import java.util.List; import java.util.Map; + +import org.junit.Ignore; import org.junit.Test; @AutoService(EndToEndTestBase.class) public class ScheduledTriggeringIT extends EndToEndTestBase { @Test + @Ignore public void testScheduledTriggeringFlyteWorkflow() throws Exception { // Generate workflow configuration var workflowJson = diff --git a/styx-scheduler-service/src/main/java/com/spotify/styx/flyte/FlyteAdminClientRunner.java b/styx-scheduler-service/src/main/java/com/spotify/styx/flyte/FlyteAdminClientRunner.java index 61a626ca36..9e67fbc829 100644 --- a/styx-scheduler-service/src/main/java/com/spotify/styx/flyte/FlyteAdminClientRunner.java +++ b/styx-scheduler-service/src/main/java/com/spotify/styx/flyte/FlyteAdminClientRunner.java @@ -84,7 +84,7 @@ public class FlyteAdminClientRunner implements FlyteRunner { @VisibleForTesting static final String STYX_WORKFLOW_INSTANCE_ANNOTATION = "styx-workflow-instance"; @VisibleForTesting static final String STYX_EXECUTION_ID_ANNOTATION = "styx-execution-id"; @VisibleForTesting static final Duration TERMINATION_GRACE_PERIOD = Duration.ofMinutes(10); - private static final Duration TERMINATION_LOOKUP_SINCE = Duration.ofDays(24); + private static final Duration TERMINATION_LOOKUP_SINCE = Duration.ofHours(24); private static final int FLYTE_TERMINATING_THREADS = 4; //TODO: tune private static final Duration DEFAULT_TERMINATE_EXEC_INTERVAL = Duration.ofMinutes(1); private static final ThreadFactory THREAD_FACTORY = new ThreadFactoryBuilder()