worker.base

Module Contents

worker.base.logger

worker.base.REQUEST_TIMEOUT = 5.0

class worker.base.RateLimitAggregate(redis, queue, daily_rate_limit, hourly_rate_limit, minutely_rate_limit, secondly_rate_limit)

Bases: polyswarmclient.ratelimit.abstractratelimit.AbstractRateLimit

daily :Optional[RedisRateLimit]

hourly :Optional[RedisRateLimit]

minutely :Optional[RedisRateLimit]

secondly :Optional[RedisRateLimit]

class worker.base.OptionalSemaphore(value=1, loop=None)

Bases: asyncio.Semaphore

given_value :int

release(self)

class worker.base.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)