jprdonnelly/kestra
1
0
Fork 0
mirror of https://github.com/kestra-io/kestra.git synced 2025-12-23 21:04:39 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: missing tenant id for flow creation in AbstractSchedulerTest (#13311)

Browse Source
This commit is contained in:
YannC
2025-12-03 15:58:52 +01:00
committed by GitHub
parent a72ecfc2eb
commit 32da15b2ea
3 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
scheduler/src/test/java/io/kestra/scheduler/AbstractSchedulerTest.java
View File

@@ -36,6 +36,8 @@ import java.util.Optional;
@KestraTest(rebuildContext = true) @KestraTest(rebuildContext = true)
abstract public class AbstractSchedulerTest { abstract public class AbstractSchedulerTest {
public final static String TENANT_ID = "main";
@Inject @Inject
protected ApplicationContext applicationContext; protected ApplicationContext applicationContext;
@@ -74,7 +76,7 @@ abstract public class AbstractSchedulerTest {
*/ */
@Deprecated @Deprecated
protected static FlowWithSource createFlow(List<AbstractTrigger> triggers) { protected static FlowWithSource createFlow(List<AbstractTrigger> triggers) {
return createFlow(null, triggers); return createFlow(TENANT_ID, triggers);
} }
protected static FlowWithSource createFlow(String tenantId, List<AbstractTrigger> triggers) { protected static FlowWithSource createFlow(String tenantId, List<AbstractTrigger> triggers) {

1
scheduler/src/test/java/io/kestra/scheduler/SchedulerConditionTest.java
View File

@@ -77,6 +77,7 @@ class SchedulerConditionTest extends AbstractSchedulerTest {
flowRepository.create(GenericFlow.of(flow)); flowRepository.create(GenericFlow.of(flow));
Trigger trigger = Trigger.builder() Trigger trigger = Trigger.builder()
.tenantId(TENANT_ID)
.namespace(flow.getNamespace()) .namespace(flow.getNamespace())
.flowId(flow.getId()) .flowId(flow.getId())
.triggerId("hourly") .triggerId("hourly")

4
scheduler/src/test/java/io/kestra/scheduler/SchedulerScheduleOnDatesTest.java
View File

@@ -90,6 +90,7 @@ public class SchedulerScheduleOnDatesTest extends AbstractSchedulerTest {
Trigger trigger = Trigger Trigger trigger = Trigger
.builder() .builder()
.tenantId(TENANT_ID)
.triggerId("schedule") .triggerId("schedule")
.flowId(flow.getId()) .flowId(flow.getId())
.namespace(flow.getNamespace()) .namespace(flow.getNamespace())
@@ -145,6 +146,7 @@ public class SchedulerScheduleOnDatesTest extends AbstractSchedulerTest {
ZonedDateTime lastDate = ZonedDateTime.now().minusHours(3L); ZonedDateTime lastDate = ZonedDateTime.now().minusHours(3L);
Trigger lastTrigger = Trigger Trigger lastTrigger = Trigger
.builder() .builder()
.tenantId(TENANT_ID)
.triggerId("recoverALLMissing") .triggerId("recoverALLMissing")
.flowId(flow.getId()) .flowId(flow.getId())
.namespace(flow.getNamespace()) .namespace(flow.getNamespace())
@@ -196,6 +198,7 @@ public class SchedulerScheduleOnDatesTest extends AbstractSchedulerTest {
ZonedDateTime lastDate = ZonedDateTime.now().minusHours(3L); ZonedDateTime lastDate = ZonedDateTime.now().minusHours(3L);
Trigger lastTrigger = Trigger Trigger lastTrigger = Trigger
.builder() .builder()
.tenantId(TENANT_ID)
.triggerId("recoverLASTMissing") .triggerId("recoverLASTMissing")
.flowId(flow.getId()) .flowId(flow.getId())
.namespace(flow.getNamespace()) .namespace(flow.getNamespace())
@@ -248,6 +251,7 @@ public class SchedulerScheduleOnDatesTest extends AbstractSchedulerTest {
ZonedDateTime lastDate = ZonedDateTime.now().minusHours(3L); ZonedDateTime lastDate = ZonedDateTime.now().minusHours(3L);
Trigger lastTrigger = Trigger Trigger lastTrigger = Trigger
.builder() .builder()
.tenantId(TENANT_ID)
.triggerId("recoverNONEMissing") .triggerId("recoverNONEMissing")
.flowId(flow.getId()) .flowId(flow.getId())
.namespace(flow.getNamespace()) .namespace(flow.getNamespace())