File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change @@ -297,7 +297,7 @@ impl Engine for EngineService {
297297 } ;
298298 let mut mem_tsks = api. task_queue . clone ( ) ;
299299 let mut mem_tsk = mem_tsks. tasks . get ( & id) . unwrap ( ) . clone ( ) ;
300- mem_tsk. push ( tbp_tsk) ;
300+ mem_tsk. push ( tbp_tsk. clone ( ) ) ;
301301 mem_tsks. tasks . insert ( id. clone ( ) , mem_tsk) ;
302302 api. task_queue = mem_tsks;
303303 api. db
@@ -306,6 +306,12 @@ impl Engine for EngineService {
306306 bincode:: serialize ( & api. task_queue . clone ( ) ) . unwrap ( ) ,
307307 )
308308 . unwrap ( ) ;
309+ return Ok ( tonic:: Response :: new ( proto:: Task {
310+ id : tbp_tsk. id . clone ( ) ,
311+ task_id : task_id. clone ( ) ,
312+ payload : Vec :: new ( ) ,
313+ task_payload : tbp_tsk. bytes . clone ( ) ,
314+ } ) ) ;
309315 }
310316 Err ( tonic:: Status :: aborted ( "Error" ) )
311317 }
You can’t perform that action at this time.
0 commit comments