File tree Expand file tree Collapse file tree
crates/fluxqueue-worker/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -14,19 +14,6 @@ use crate::redis_client::RedisClient;
1414use crate :: task:: { PythonDispatcher , TaskRegistry } ;
1515use fluxqueue_common:: { Task , deserialize_raw_task_data} ;
1616
17- struct ExecutorContext {
18- queue_name : Arc < str > ,
19- executor_id : Arc < str > ,
20- redis_client : Arc < RedisClient > ,
21- task_registry : Arc < TaskRegistry > ,
22- python_dispatcher : Arc < PythonDispatcher > ,
23- }
24-
25- struct ReadyCheck {
26- concurrency : Arc < AtomicUsize > ,
27- counter : Arc < AtomicUsize > ,
28- }
29-
3017pub async fn run_worker (
3118 mut shutdown : watch:: Receiver < bool > ,
3219 concurrency : usize ,
@@ -148,6 +135,19 @@ pub async fn run_worker(
148135 Ok ( ( ) )
149136}
150137
138+ struct ExecutorContext {
139+ queue_name : Arc < str > ,
140+ executor_id : Arc < str > ,
141+ redis_client : Arc < RedisClient > ,
142+ task_registry : Arc < TaskRegistry > ,
143+ python_dispatcher : Arc < PythonDispatcher > ,
144+ }
145+
146+ struct ReadyCheck {
147+ concurrency : Arc < AtomicUsize > ,
148+ counter : Arc < AtomicUsize > ,
149+ }
150+
151151async fn executor_loop (
152152 mut shutdown : watch:: Receiver < bool > ,
153153 ready_check : ReadyCheck ,
You can’t perform that action at this time.
0 commit comments