@@ -1312,14 +1312,16 @@ void shouldPauseExecutionByIdsRunningFlows() throws TimeoutException, QueueExcep
1312
1312
}
1313
1313
1314
1314
@ Test
1315
- @ LoadFlows ({"flows/valids/sleep.yml" })
1315
+ @ LoadFlows ({"flows/valids/sleep-short.yml" })
1316
+ // use a dedicated Flow to avoid clash with other tests
1316
1317
void shouldPauseExecutionByQueryRunningFlows () throws TimeoutException , QueueException {
1317
- Execution result1 = runnerUtils .runOneUntilRunning (null , "io.kestra.tests" , "sleep" );
1318
- Execution result2 = runnerUtils .runOneUntilRunning (null , "io.kestra.tests" , "sleep" );
1319
- Execution result3 = runnerUtils .runOneUntilRunning (null , "io.kestra.tests" , "sleep" );
1318
+ var flowId = "sleep-short" ;
1319
+ Execution result1 = runnerUtils .runOneUntilRunning (null , "io.kestra.tests" , flowId );
1320
+ Execution result2 = runnerUtils .runOneUntilRunning (null , "io.kestra.tests" , flowId );
1321
+ Execution result3 = runnerUtils .runOneUntilRunning (null , "io.kestra.tests" , flowId );
1320
1322
1321
1323
BulkResponse response = client .toBlocking ().retrieve (
1322
- HttpRequest .POST ("/api/v1/executions/pause/by-query?namespace=" + result1 .getNamespace (), null ),
1324
+ HttpRequest .POST ("/api/v1/executions/pause/by-query?flowId=" + flowId + "& namespace=" + result1 .getNamespace (), null ),
1323
1325
BulkResponse .class
1324
1326
);
1325
1327
assertThat (response .getCount ()).isEqualTo (3 );
0 commit comments