Skip to content

Commit efcd1dc

Browse files
shanickymergify[bot]
authored andcommitted
chore: re-add force tick (#5857)
revert force tick Signed-off-by: Peng Chen <[email protected]> Signed-off-by: Peng Chen <[email protected]> Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
1 parent e068ec3 commit efcd1dc

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/meta/src/stream/source_manager.rs

+1
Original file line numberDiff line numberDiff line change
@@ -618,6 +618,7 @@ where
618618
let (sync_call_tx, sync_call_rx) = tokio::sync::mpsc::unbounded_channel();
619619

620620
let handle = tokio::spawn(async move { worker.run(sync_call_rx).await });
621+
621622
managed_sources.insert(
622623
source.id,
623624
ConnectorSourceWorkerHandle {

0 commit comments

Comments
 (0)