You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The celery result has different task meta-id in different nodes of redis cluster. Accessing via the same id, without knowing which node has it, would give MOVED error. How can I have the same result distributed and available to all nodes?
#6
Open
harryz2016 opened this issue
Jul 8, 2024
· 0 comments
I managed to connect the package to my redis cluster. The celery worker is able to pick up tasks from rabbitMQ and send result to Redis Cluster. However, the result has different task meta-id in different nodes of redis cluster. Accessing via the same id would give MOVED error.
Here is the Redis-cli log:
127.0.0.1:7000> get celery-task-meta-086d27bd-fcd0-423c-9e32-1a677c30dfbb
"{"status": "SUCCESS", "result": "hello Harry", "traceback": null, "children": [], "date_done": "2024-07-08T13:02:16.663910", "task_id": "086d27bd-fcd0-423c-9e32-1a677c30dfbb"}"
127.0.0.1:7001> get celery-task-meta-086d27bd-fcd0-423c-9e32-1a677c30dfbb
(error) MOVED 2614 127.0.0.1:7000
How can I have the same result distributed and available to all nodes?
The text was updated successfully, but these errors were encountered:
harryz2016
changed the title
The celery result is only in one node of the redis cluster. How can I have that result distributed and available to all nodes?
The celery result has different task meta-id in different nodes of redis cluster. Accessing via the same id, without knowing which node has it, would give MOVED error. How can I have the same result distributed and available to all nodes?
Jul 8, 2024
I managed to connect the package to my redis cluster. The celery worker is able to pick up tasks from rabbitMQ and send result to Redis Cluster. However, the result has different task meta-id in different nodes of redis cluster. Accessing via the same id would give MOVED error.
Here is the Redis-cli log:
127.0.0.1:7000> get celery-task-meta-086d27bd-fcd0-423c-9e32-1a677c30dfbb
"{"status": "SUCCESS", "result": "hello Harry", "traceback": null, "children": [], "date_done": "2024-07-08T13:02:16.663910", "task_id": "086d27bd-fcd0-423c-9e32-1a677c30dfbb"}"
127.0.0.1:7001> get celery-task-meta-086d27bd-fcd0-423c-9e32-1a677c30dfbb
(error) MOVED 2614 127.0.0.1:7000
127.0.0.1:7001> KEYS *
127.0.0.1:7001> GET celery-task-meta-0bfef6f4-db1a-49f6-bc1a-4f9402111302
"{"status": "SUCCESS", "result": "hello Harry", "traceback": null, "children": [], "date_done": "2024-07-08T13:01:37.958727", "task_id": "0bfef6f4-db1a-49f6-bc1a-4f9402111302"}"
How can I have the same result distributed and available to all nodes?
The text was updated successfully, but these errors were encountered: