File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -432,11 +432,11 @@ def work_init(self):
432432 if self .config ["paused_queues_refresh_interval" ] > 0 :
433433 self .greenlets ["paused_queues" ] = gevent .spawn (self .greenlet_paused_queues )
434434
435- self .greenlets ["report" ] = gevent .spawn (self .greenlet_report )
435+ if self .config ["report_interval" ] > 0 :
436+ self .greenlets ["report" ] = gevent .spawn (self .greenlet_report )
437+ self .greenlets ["logs" ] = gevent .spawn (self .greenlet_logs )
436438
437- self .greenlets ["logs" ] = gevent .spawn (self .greenlet_logs )
438-
439- if self .config ["scheduler" ]:
439+ if self .config ["scheduler" ] and self .config ["scheduler_interval" ] > 0 :
440440 self .greenlets ["scheduler" ] = gevent .spawn (self .greenlet_scheduler )
441441
442442 if self .config ["admin_port" ]:
Original file line number Diff line number Diff line change @@ -52,7 +52,7 @@ def test_memoryleaks_noleak(worker):
5252 # TRACE = "--trace_memory_type ObjectId"
5353
5454 worker .start (
55- flags = "--trace_memory --greenlets 1 --mongodb_logs 0 --report_interval 10000 %s" % TRACE )
55+ flags = "--trace_memory --greenlets 1 --mongodb_logs 0 --scheduler_interval 0 --subqueues_refresh_interval 0 --paused_queues_refresh_interval 0 -- report_interval 10000 %s" % TRACE )
5656
5757 # Send it once to add to imports
5858 get_diff_after_jobs (worker , 10 , 0 )
You can’t perform that action at this time.
0 commit comments