From 3fb3fb18c276d20fa9c566fab1e896a434e4dd47 Mon Sep 17 00:00:00 2001 From: discord9 Date: Fri, 26 Apr 2024 15:36:36 +0800 Subject: [PATCH] tests: add one for Send --- src/flow/src/adapter.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/flow/src/adapter.rs b/src/flow/src/adapter.rs index b4c8f72539..532ea366a6 100644 --- a/src/flow/src/adapter.rs +++ b/src/flow/src/adapter.rs @@ -63,10 +63,14 @@ pub struct FlowNodeManager<'subgraph> { tick_manager: FlowTickManager, } +/// Just check if NodeManager's other fields are `Send` so later we can refactor so A Flow Node Manager +/// can manage multiple flow worker(thread) then we can run multiple flow worker in a single flow node manager #[test] -fn check() { +fn check_is_send() { fn is_send() {} + is_send::(); is_send::(); + is_send::(); } /// mapping of table name <-> table id should be query from tableinfo manager