worker

Submodules

• worker.__main__
• worker.base
• worker.exceptions

Package Contents

class worker.Worker(redis_addr, queue, task_count=0, download_limit=0, scan_limit=0, api_key=None, testing=0, scanner=None, scan_time_requirement=0, daily_rate_limit=None, hourly_rate_limit=None, minutely_rate_limit=None, secondly_rate_limit=None, allow_key_over_http=False)

run(self)

start(self, loop: asyncio.AbstractEventLoop)

setup_synchronization(self, loop: asyncio.AbstractEventLoop)

setup_graceful_shutdown(self, loop: asyncio.AbstractEventLoop)

handle_signal(self)

get_remaining_time(self, job: JobRequest)

rate_limit_respond(self, job: JobRequest)

is_key_secure(self, job: JobRequest)