# celery -A tasks worker --loglevel=INFO
 
 -------------- celery@DESKTOP-BQAR0JR v5.3.6 (emerald-rush)
--- ***** -----
-- ******* ---- Windows-10-10.0.19045-SP0 2023-12-06 11:01:05
- *** --- * ---
- ** ---------- [config]
- ** ---------- .> app:         tasks:0x1a7532b6340
- ** ---------- .> transport:   redis://192.168.1.105:6379/0
- ** ---------- .> results:     redis://192.168.1.105/0
- *** --- * --- .> concurrency: 8 (prefork)
-- ******* ---- .> task events: OFF (enable -E to monitor tasks in this worker)
--- ***** -----
 -------------- [queues]
                .> celery           exchange=celery(direct) key=celery


[tasks]
  . tasks.add

[2023-12-06 11:01:05,903: WARNING/MainProcess] c:\users\administrator\appdata\local\programs\py
thon\python38\lib\site-packages\celery\worker\consumer\consumer.py:507: CPendingDeprecationWarn
ing: The broker_connection_retry configuration setting will no longer determine
whether broker connection retries are made during startup in Celery 6.0 and above.
If you wish to retain the existing behavior for retrying connections on startup,
you should set broker_connection_retry_on_startup to True.
  warnings.warn(

[2023-12-06 11:01:06,037: INFO/MainProcess] Connected to redis://192.168.1.105:6379/0
[2023-12-06 11:01:06,039: WARNING/MainProcess] c:\users\administrator\appdata\local\programs\py
thon\python38\lib\site-packages\celery\worker\consumer\consumer.py:507: CPendingDeprecationWarn
[2023-12-06 11:01:06,864: INFO/SpawnPoolWorker-7] child process 12484 calling self.run()       
[2023-12-06 11:01:06,867: INFO/SpawnPoolWorker-5] child process 21516 calling self.run()       
[2023-12-06 11:01:07,680: INFO/MainProcess] mingle: all alone
[2023-12-06 11:01:08,304: INFO/MainProcess] celery@DESKTOP-BQAR0JR ready.
[2023-12-06 11:01:44,627: INFO/MainProcess] Task tasks.add[2e88f4bd-aebb-4f80-a0dc-c34ea27a4a22
] received
[2023-12-06 11:01:44,806: ERROR/MainProcess] Task handler raised error: ValueError('not enough 
values to unpack (expected 3, got 0)')
billiard.einfo.RemoteTraceback:
"""
Traceback (most recent call last):
  File "c:\users\administrator\appdata\local\programs\python\python38\lib\site-packages\billiar
d\pool.py", line 361, in workloop
    result = (True, prepare_result(fun(*args, **kwargs)))
Traceback (most recent call last):
  File "c:\users\administrator\appdata\local\programs\python\python38\lib\site-packages\billiar
d\pool.py", line 361, in workloop
    result = (True, prepare_result(fun(*args, **kwargs)))
  File "c:\users\administrator\appdata\local\programs\python\python38\lib\site-packages\celery\
app\trace.py", line 664, in fast_trace_task
    tasks, accept, hostname = _loc
ValueError: not enough values to unpack (expected 3, got 0)
worker: Hitting Ctrl+C again will terminate all running tasks!

# coding=utf-8

from tasks import add

result = add.delay(4,4)
print('Is task ready: %s' % result.ready())

run_result = result.get(timeout=1)
print('Task Result: %s' % run_result)

#安装依赖
pip install eventlet


#运行work server指定eventlet
celery -A <mymodule> worker -l info -P eventlet