# Path: kale/worker.py
# SIGNALS_TO_HANDLE = (
#     signal.SIGABRT,
#     # This will catch Ctrl-C interrupts.
#     signal.SIGINT,
#     signal.SIGQUIT,
#     signal.SIGTERM,
#     # Handle Ctrl-Z/suspend.
#     signal.SIGTSTP)
# LOG_TASK_RESULT_DEFERRED = 'deferred'
# LOG_TASK_RESULT_ERROR = 'error'
# LOG_TASK_RESULT_SUCCESS = 'success'
# class Worker(object):
#     def __init__(self):
#     def _get_publisher():
#     def _on_pre_run_worker(self):
#     def _on_exceeding_memory_limit(self, ru_maxrss_mb):
#     def _on_sigtstp(self, num_completed, num_incomplete):
#     def _on_shutdown(self, num_completed, num_incomplete):
#     def _on_pre_batch_run(self, messages):
#     def _on_post_batch_run(self, num_completed, num_incomplete, messages):
#     def _on_permanent_failure_batch(self):
#     def _on_task_deferred(self, message, time_remaining_sec):
#     def _on_task_failed(self, message, time_remaining_sec, err,
#                         permanent_failure):
#     def _on_task_succeeded(self, message, time_remaining_sec):
#     def run(self):
#     def _check_process_resources(self):
#     def _cleanup_worker(self, signum, frame):
#     def _run_single_iteration(self):
#     def _release_batch(self):
#     def _run_batch(self, message_batch):
#     def _run_single_message(self, message, time_remaining_sec):
#     def remove_message_or_exit(self, message):
#     def should_run_task(self, message):
#     def run_task(self, message):


from kale import worker
from __future__ import absolute_import
from __future__ import print_function



if __name__ == '__main__':
    print('Task worker is running ...')

# Path: kale/worker.py
# SIGNALS_TO_HANDLE = (
#     signal.SIGABRT,
#     # This will catch Ctrl-C interrupts.
#     signal.SIGINT,
#     signal.SIGQUIT,
#     signal.SIGTERM,
#     # Handle Ctrl-Z/suspend.
#     signal.SIGTSTP)
# LOG_TASK_RESULT_DEFERRED = 'deferred'
# LOG_TASK_RESULT_ERROR = 'error'
# LOG_TASK_RESULT_SUCCESS = 'success'
# class Worker(object):
#     def __init__(self):
#     def _get_publisher():
#     def _on_pre_run_worker(self):
#     def _on_exceeding_memory_limit(self, ru_maxrss_mb):
#     def _on_sigtstp(self, num_completed, num_incomplete):
#     def _on_shutdown(self, num_completed, num_incomplete):
#     def _on_pre_batch_run(self, messages):
#     def _on_post_batch_run(self, num_completed, num_incomplete, messages):
#     def _on_permanent_failure_batch(self):
#     def _on_task_deferred(self, message, time_remaining_sec):
#     def _on_task_failed(self, message, time_remaining_sec, err,
#                         permanent_failure):
#     def _on_task_succeeded(self, message, time_remaining_sec):
#     def run(self):
#     def _check_process_resources(self):
#     def _cleanup_worker(self, signum, frame):
#     def _run_single_iteration(self):
#     def _release_batch(self):
#     def _run_batch(self, message_batch):
#     def _run_single_message(self, message, time_remaining_sec):
#     def remove_message_or_exit(self, message):
#     def should_run_task(self, message):
#     def run_task(self, message):


# Path: example/worker.py
from kale import worker

from __future__ import absolute_import
from __future__ import print_function



if __name__ == '__main__':
    print('Task worker is running ...')

    worker.Worker().run()