File tree Expand file tree Collapse file tree 4 files changed +17
-19
lines changed
Expand file tree Collapse file tree 4 files changed +17
-19
lines changed Original file line number Diff line number Diff line change @@ -179,18 +179,16 @@ void missing() throws Exception {
179179 }
180180 });
181181
182+ String file = FriendlyId .createFriendlyId ();
183+ utils ().upload ("/upload/trigger/missing/" + triggeringFlowId () + "/" + file );
182184
183185 worker .run ();
184186 scheduler .run ();
185187 repositoryLoader .load (Objects .requireNonNull (AbstractFileTriggerTest .class .getClassLoader ().getResource ("flows" )));
186188
187- Thread .sleep (1000 );
188-
189- String file = FriendlyId .createFriendlyId ();
190- utils ().upload ("/upload/trigger/missing/" + triggeringFlowId () + "/" + file );
191-
192189 boolean await = queueCount .await (10 , TimeUnit .SECONDS );
193190 assertThat (await , is (true ));
191+ receive .blockLast ();
194192
195193 @ SuppressWarnings ("unchecked" )
196194 java .util .List <URI > trigger = (java .util .List <URI >) last .get ().getTrigger ().getVariables ().get ("files" );
Original file line number Diff line number Diff line change 1- id : sftp -listen
1+ id : ftp -listen-missing
22namespace : io.kestra.tests
33
44triggers :
55 - id : watch
6- type : io.kestra.plugin.fs.sftp .Trigger
6+ type : io.kestra.plugin.fs.ftp .Trigger
77 host : localhost
8- port : 6622
9- username : foo
10- password : pass*+=
11- from : " /upload/trigger/missing/ftp-listen"
8+ port : 6621
9+ username : guest
10+ password : O7m)&H/0Em4/T8RqCa!Al=M@N6^;@+
11+ from : " /upload/trigger/missing/ftp-listen/ "
1212 interval : PT10S
1313 action : MOVE
1414 moveDirectory : " /upload/trigger-move/"
Original file line number Diff line number Diff line change 1- id : sftp-listen
1+ id : sftp-listen-missing
22namespace : io.kestra.tests
33
44triggers :
@@ -8,7 +8,7 @@ triggers:
88 port : 6622
99 username : foo
1010 password : pass*+=
11- from : " /upload/trigger/missing/sftp-listen"
11+ from : " /upload/trigger/missing/sftp-listen/ "
1212 interval : PT10S
1313 action : MOVE
1414 moveDirectory : " /upload/trigger-move/"
Original file line number Diff line number Diff line change 1- src/test/resources/flows/ smb-listen-missing.yamlid : sftp-listen
1+ id : smb-listen-missing
22namespace : io.kestra.tests
33
44triggers :
55 - id : watch
6- type : io.kestra.plugin.fs.sftp .Trigger
6+ type : io.kestra.plugin.fs.smb .Trigger
77 host : localhost
8- port : 6622
9- username : foo
10- password : pass*+=
11- from : " /upload/trigger/missing/smb-listen"
8+ port : " 445 "
9+ username : alice
10+ password : O7m)&H/0Em4/T8RqCa!Al=M@N6^;@+
11+ from : " /upload/trigger/missing/smb-listen/ "
1212 interval : PT10S
1313 action : MOVE
1414 moveDirectory : " /upload/trigger-move/"
You can’t perform that action at this time.
0 commit comments