Comments (9)
liuliqiang
commented on September 15, 2024
Let me check what's wrong.
from redisbeat.
liuliqiang
commented on September 15, 2024
@isaqueprofeta what's the python version for your enviroment?
from redisbeat.
isaqueprofeta
commented on September 15, 2024
I'm using 3.6 atm.
from redisbeat.
liuliqiang
commented on September 15, 2024
It seems works well in my try.
- Get the source code in this repo
$ git clone [email protected]:liuliqiang/celerybeatredis.git
$ cd celerybeatredis/example
- run redis
$ docker run --rm -d -p 6379:6379 redis:5.0.4
- run celery worker
$ celery worker -A tasks -l info
- run celery client
celery beat -A tasks -S redisbeat.RedisScheduler
celery beat v4.3.0 (rhubarb) is starting.
__ - ... __ - _
LocalTime -> 2019-09-05 10:47:01
Configuration ->
. broker -> redis://localhost:6379//
. loader -> celery.loaders.app.AppLoader
. scheduler -> redisbeat.scheduler.RedisScheduler
. db -> redis://localhost:6379, key -> celery:beat:order_tasks
. logfile -> [stderr]@%WARNING
. maxinterval -> 5.00 minutes (300s)
- I get the output in worker:
. tasks.sub
[2019-09-05 10:49:04,494: INFO/MainProcess] Connected to redis://localhost:6379//
[2019-09-05 10:49:04,502: INFO/MainProcess] mingle: searching for neighbors
[2019-09-05 10:49:05,529: INFO/MainProcess] mingle: all alone
[2019-09-05 10:49:05,558: INFO/MainProcess] celery@china ready.
[2019-09-05 10:49:05,775: INFO/MainProcess] Received task: tasks.add[f29603d9-05ab-4e28-8f03-7f8186394f62]
[2019-09-05 10:49:05,781: INFO/MainProcess] Received task: tasks.add[8847654c-cb87-43aa-b274-f19108b703b2]
[2019-09-05 10:49:05,786: INFO/MainProcess] Received task: tasks.add[309067d2-5d4d-495d-9dd2-0a1b6cf848f8]
[2019-09-05 10:49:05,799: INFO/ForkPoolWorker-4] Task tasks.add[f29603d9-05ab-4e28-8f03-7f8186394f62] succeeded in 0.020004888996481895s: 2
[2019-09-05 10:49:05,803: INFO/MainProcess] Received task: tasks.add[fc3d511c-cb68-4935-8bd6-d1e7cf11aef4]
[2019-09-05 10:49:05,808: INFO/ForkPoolWorker-1] Task tasks.add[309067d2-5d4d-495d-9dd2-0a1b6cf848f8] succeeded in 0.01581715198699385s: 2
[2019-09-05 10:49:05,812: INFO/MainProcess] Received task: tasks.add[7ed89bd6-5191-4562-bf44-85970dc35f44]
[2019-09-05 10:49:05,812: INFO/ForkPoolWorker-3] Task tasks.add[8847654c-cb87-43aa-b274-f19108b703b2] succeeded in 0.022550783003680408s: 2
[2019-09-05 10:49:05,814: INFO/ForkPoolWorker-4] Task tasks.add[7ed89bd6-5191-4562-bf44-85970dc35f44] succeeded in 0.0007537500932812691s: 2
... ...
from redisbeat.
liuliqiang
commented on September 15, 2024
Enviroment version is following:
(py3) ➜ example git:(master) python --version
Python 3.6.6
(py3) ➜ example git:(master) pip freeze | grep celery
celery==4.3.0
(py3) ➜ example git:(master) pip freeze | grep redis
redis==3.3.8
redisbeat==1.1.4
(py3) ➜ example git:(master) pip freeze | grep json
jsonpickle==1.0
from redisbeat.
isaqueprofeta
commented on September 15, 2024
Oh sure. The worker is fine.
The output of beat in the setup_schedule function is the culprit I'm pointing out.
Look at beat logs, you'll see that in info level it's not spilling out the list from redis query.
It only shows "Current Schedule" and blank.
from redisbeat.
liuliqiang
commented on September 15, 2024
Oh...I get the error..
It's a bug, thanks for your report @isaqueprofeta .
Would you mind to take a better fix?
And i think jsonpickle.encode is not a good format.
from redisbeat.
isaqueprofeta
commented on September 15, 2024
I'm trying some tweaks here on my side. Need to do a little trip tomorrow, but next week I'm pretty sure to come up with something.
from redisbeat.
liuliqiang
commented on September 15, 2024
That's Ok, i assign the task for you now.
from redisbeat.
Related Issues (20)
- 请问celery如何动态创建task？ HOT 6
- Remote Redis HOT 3
- ImportError: Missing redis library (pip install redis) HOT 12
- "remove" seems doesn't work HOT 3
- redisbeat 1.1.0 does not have the latest changes for python3 HOT 3
- CELERY_REDIS_SCHEDULER_URL with password is not working HOT 2
- Add a docker-compose demo HOT 8
- Support for redis sentinel HOT 2
- Add support for PeriodicTask tasks
- AttributeError: 'crontab' object has no attribute 'human_seconds' HOT 2
- each time init RedisScheduler - repeated call HOT 2
- 新增task 问题 HOT 1
- [feature] functionality to execute the task as django-celery-beat does: HOT 2
- How to setup an Timzone properly?
- Problematic dependency on jsonpickle==1.2 HOT 2
- 第80行的task为bytes类型 HOT 2
- version 1.2.5 is broken HOT 2
- jsonpickle issues parsing datetime HOT 2
- Hi, I encountered the following error while using this framework. Could you please advise on how to resolve it? My Redis is in cluster mode. HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from redisbeat.