diff options
| author | Thomas Grainger <tagrain@gmail.com> | 2021-07-20 14:07:49 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-07-20 19:07:49 +0600 |
| commit | 241b5dcff8a7c8ad411e1b325d59e47acfa9e1ed (patch) | |
| tree | 14b5c70fb2e2e2e4c53356d8a21da0540da16759 /examples/simple_task_queue | |
| parent | 1ce0afe39ab26487c1cdfd9d4ba8c5bb445c8f32 (diff) | |
| download | kombu-241b5dcff8a7c8ad411e1b325d59e47acfa9e1ed.tar.gz | |
enable pre-commit (#1355)
* enable pre-commit
* use extend-ignore for flake8
* manual flake8 fixes
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* [pre-commit.ci] auto fixes from pre-commit.com hooks
for more information, see https://pre-commit.ci
* Update kombu/__init__.py
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
Diffstat (limited to 'examples/simple_task_queue')
| -rw-r--r-- | examples/simple_task_queue/client.py | 2 | ||||
| -rw-r--r-- | examples/simple_task_queue/worker.py | 4 |
2 files changed, 5 insertions, 1 deletions
diff --git a/examples/simple_task_queue/client.py b/examples/simple_task_queue/client.py index e19b9476..bc2d180f 100644 --- a/examples/simple_task_queue/client.py +++ b/examples/simple_task_queue/client.py @@ -21,8 +21,10 @@ def send_as_task(connection, fun, args=(), kwargs={}, priority='mid'): declare=[task_exchange], routing_key=routing_key) + if __name__ == '__main__': from kombu import Connection + from .tasks import hello_task connection = Connection('amqp://guest:guest@localhost:5672//') diff --git a/examples/simple_task_queue/worker.py b/examples/simple_task_queue/worker.py index 14064ccf..66ad9c30 100644 --- a/examples/simple_task_queue/worker.py +++ b/examples/simple_task_queue/worker.py @@ -1,5 +1,5 @@ -from kombu.mixins import ConsumerMixin from kombu.log import get_logger +from kombu.mixins import ConsumerMixin from kombu.utils.functional import reprcall from .queues import task_queues @@ -28,9 +28,11 @@ class Worker(ConsumerMixin): logger.error('task raised exception: %r', exc) message.ack() + if __name__ == '__main__': from kombu import Connection from kombu.utils.debug import setup_logging + # setup root logger setup_logging(loglevel='INFO', loggers=['']) |