This is an automated email from the ASF dual-hosted git repository.
He-Pin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 98f26fd80 Fix unit test related to ftp timeout (#1629)
98f26fd80 is described below
commit 98f26fd80d89b5cc97528c15bc67a03b0e8cc9e7
Author: Cristi <[email protected]>
AuthorDate: Mon May 25 13:57:35 2026 +0300
Fix unit test related to ftp timeout (#1629)
* Fix unit test related to ftp timeout
This PR fixes the ftp unit test issue reported in #1581 by increasing the
timeout for the test to 4 seconds.
* Increase timeout to 8s for slower github workers
---
ftp/src/test/scala/docs/scaladsl/FtpExamplesSpec.scala | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/ftp/src/test/scala/docs/scaladsl/FtpExamplesSpec.scala
b/ftp/src/test/scala/docs/scaladsl/FtpExamplesSpec.scala
index d15209392..5f2bcfea4 100644
--- a/ftp/src/test/scala/docs/scaladsl/FtpExamplesSpec.scala
+++ b/ftp/src/test/scala/docs/scaladsl/FtpExamplesSpec.scala
@@ -64,8 +64,7 @@ class FtpExamplesSpec
}
"a file" should {
- // https://github.com/apache/pekko-connectors/issues/1581 open to try to
get this fixed
- "be stored" ignore assertAllStagesStopped {
+ "be stored" in assertAllStagesStopped {
// #storing
import org.apache.pekko
import pekko.stream.IOResult
@@ -78,7 +77,7 @@ class FtpExamplesSpec
.runWith(Ftp.toPath("file.txt", ftpSettings))
// #storing
- val ioResult = result.futureValue(timeout(Span(1, Seconds)))
+ val ioResult = result.futureValue(timeout(Span(8, Seconds)))
ioResult should be(IOResult.createSuccessful(25))
val p = fileExists("file.txt")
@@ -86,8 +85,7 @@ class FtpExamplesSpec
}
- // https://github.com/apache/pekko-connectors/issues/1581 open to try to
get this fixed
- "be gzipped" ignore assertAllStagesStopped {
+ "be gzipped" in assertAllStagesStopped {
import pekko.stream.IOResult
import pekko.stream.connectors.ftp.scaladsl.Ftp
import pekko.util.ByteString
@@ -103,7 +101,7 @@ class FtpExamplesSpec
.runWith(Ftp.toPath("file.txt.gz", ftpSettings))
// #storing
- val ioResult = result.futureValue(timeout(Span(1, Seconds)))
+ val ioResult = result.futureValue(timeout(Span(8, Seconds)))
ioResult should be(IOResult.createSuccessful(61))
val p = fileExists("file.txt.gz")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
