alligator.workers¶
-
class
alligator.workers.Worker(gator, max_tasks=0, to_consume='all', nap_time=0.1, log_level=20)¶ -
check_and_run_task()¶ Handles the logic of checking for & executing a task.
Worker.run_forever uses this in a loop to actually handle the main logic, though you can call this on your own if you have different needs.
Returns: - True if a task was run successfully, False if there was
- no task to process or executing the task failed.
Return type: bool
-
get_log(log_level=20)¶ Sets up logging for the instance.
Parameters: log_level (int) – Optional. The logging level you’d like for output. Default is logging.INFO. Returns: The log instance. Return type: logging.Logger
-
ident()¶ Returns a string identifier for the worker.
Used in the printed messages & includes the process ID.
-
interrupt()¶ Prints an interrupt message to stdout.
-
result(result)¶ Prints the received result from a task to stdout.
Parameters: result – The result of the task
-
run_forever()¶ Causes the worker to run either forever or until the Worker.max_tasks are reached.
-
starting()¶ Prints a startup message to stdout.
-
stopping()¶ Prints a shutdown message to stdout.
-