diff --git a/packages/library-sync/src/commonMain/kotlin/io/realm/kotlin/mongodb/internal/SyncSessionImpl.kt b/packages/library-sync/src/commonMain/kotlin/io/realm/kotlin/mongodb/internal/SyncSessionImpl.kt
index c7dd207ae4..078e0fe198 100644
--- a/packages/library-sync/src/commonMain/kotlin/io/realm/kotlin/mongodb/internal/SyncSessionImpl.kt
+++ b/packages/library-sync/src/commonMain/kotlin/io/realm/kotlin/mongodb/internal/SyncSessionImpl.kt
@@ -121,6 +121,7 @@ internal open class SyncSessionImpl(
                         },
                         progressMode == ProgressMode.INDEFINITELY
                     ) { progressEstimate: Double ->
+                        println("PROGRESS-CALLBACK: $progressEstimate")
                         val progress = Progress(progressEstimate)
                         trySendWithBufferOverflowCheck(progress)
                         if (progressMode == ProgressMode.CURRENT_CHANGES && progress.isTransferComplete) {
diff --git a/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt b/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt
index 833c462e63..e635d37005 100644
--- a/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt
+++ b/packages/test-sync/src/commonTest/kotlin/io/realm/kotlin/test/mongodb/common/FLXProgressListenerTests.kt
@@ -296,6 +296,7 @@ class FLXProgressListenerTests {
             .initialSubscriptions {
                 add(it.query<SyncObjectWithAllTypes>("stringField = $0", getTestPartitionValue()))
             }
+            .waitForInitialRemoteData(TIMEOUT)
             .build()
     }