(self, concurrency=None, loglevel='WARN', logfile=None,
task_events=None, pool=None, consumer_cls=None,
timer_cls=None, timer_precision=None,
autoscaler_cls=None,
pool_putlocks=None,
pool_restarts=None,
optimization=None, O=None, # O maps to -O=fair
statedb=None,
time_limit=None,
soft_time_limit=None,
scheduler=None,
pool_cls=None, # XXX use pool
state_db=None, # XXX use statedb
task_time_limit=None, # XXX use time_limit
task_soft_time_limit=None, # XXX use soft_time_limit
scheduler_cls=None, # XXX use scheduler
schedule_filename=None,
max_tasks_per_child=None,
prefetch_multiplier=None, disable_rate_limits=None,
worker_lost_wait=None,
max_memory_per_child=None, **_kw)
| 349 | return state |
| 350 | |
| 351 | def setup_defaults(self, concurrency=None, loglevel='WARN', logfile=None, |
| 352 | task_events=None, pool=None, consumer_cls=None, |
| 353 | timer_cls=None, timer_precision=None, |
| 354 | autoscaler_cls=None, |
| 355 | pool_putlocks=None, |
| 356 | pool_restarts=None, |
| 357 | optimization=None, O=None, # O maps to -O=fair |
| 358 | statedb=None, |
| 359 | time_limit=None, |
| 360 | soft_time_limit=None, |
| 361 | scheduler=None, |
| 362 | pool_cls=None, # XXX use pool |
| 363 | state_db=None, # XXX use statedb |
| 364 | task_time_limit=None, # XXX use time_limit |
| 365 | task_soft_time_limit=None, # XXX use soft_time_limit |
| 366 | scheduler_cls=None, # XXX use scheduler |
| 367 | schedule_filename=None, |
| 368 | max_tasks_per_child=None, |
| 369 | prefetch_multiplier=None, disable_rate_limits=None, |
| 370 | worker_lost_wait=None, |
| 371 | max_memory_per_child=None, **_kw): |
| 372 | either = self.app.either |
| 373 | self.loglevel = loglevel |
| 374 | self.logfile = logfile |
| 375 | |
| 376 | self.concurrency = either('worker_concurrency', concurrency) |
| 377 | self.task_events = either('worker_send_task_events', task_events) |
| 378 | self.pool_cls = either('worker_pool', pool, pool_cls) |
| 379 | self.consumer_cls = either('worker_consumer', consumer_cls) |
| 380 | self.timer_cls = either('worker_timer', timer_cls) |
| 381 | self.timer_precision = either( |
| 382 | 'worker_timer_precision', timer_precision, |
| 383 | ) |
| 384 | self.optimization = optimization or O |
| 385 | self.autoscaler_cls = either('worker_autoscaler', autoscaler_cls) |
| 386 | self.pool_putlocks = either('worker_pool_putlocks', pool_putlocks) |
| 387 | self.pool_restarts = either('worker_pool_restarts', pool_restarts) |
| 388 | self.statedb = either('worker_state_db', statedb, state_db) |
| 389 | self.schedule_filename = either( |
| 390 | 'beat_schedule_filename', schedule_filename, |
| 391 | ) |
| 392 | self.scheduler = either('beat_scheduler', scheduler, scheduler_cls) |
| 393 | self.time_limit = either( |
| 394 | 'task_time_limit', time_limit, task_time_limit) |
| 395 | self.soft_time_limit = either( |
| 396 | 'task_soft_time_limit', soft_time_limit, task_soft_time_limit, |
| 397 | ) |
| 398 | self.max_tasks_per_child = either( |
| 399 | 'worker_max_tasks_per_child', max_tasks_per_child, |
| 400 | ) |
| 401 | self.max_memory_per_child = either( |
| 402 | 'worker_max_memory_per_child', max_memory_per_child, |
| 403 | ) |
| 404 | self.prefetch_multiplier = int(either( |
| 405 | 'worker_prefetch_multiplier', prefetch_multiplier, |
| 406 | )) |
| 407 | self.disable_rate_limits = either( |
| 408 | 'worker_disable_rate_limits', disable_rate_limits, |
no outgoing calls
no test coverage detected