wait

Author: dongjoon-hyun

Tests/SparkConnectTests/DataStreamTests.swift

@@ -55,6 +55,8 @@ struct DataStreamTests {
       .trigger(Trigger.ProcessingTimeTrigger(intervalMs: 1000))
       .start(output)
     #expect(try await query.isActive)
+    // Wait for processing
+    try await Task.sleep(nanoseconds: 2_000_000_000)
 
     try await query.stop()
     #expect(try await query.isActive == false)