 Ask Solem
|
583d6ae005
Now depends on billiard>=2.7.3.6
|
13 lat temu |
|
Ask Solem
|
01925d9738
Use Process.sentinel, not Process._popen.sentinel
|
13 lat temu |
|
Ask Solem
|
e78161450c
on_process_started renamed -> on_process_up
|
13 lat temu |
|
Ask Solem
|
73ea354d3d
Tests passing
|
13 lat temu |
|
Ask Solem
|
632d80f86c
flake8
|
13 lat temu |
|
Ask Solem
|
f5834afa20
Fixes typo
|
13 lat temu |
|
Ask Solem
|
9ac95c7020
Merge branch 'hub_semaphore'
|
13 lat temu |
|
Ask Solem
|
54d160a0b5
Adds @task(bare=True) which mean the worker will execute the task directly, without calling callbacks, writing results etc.
|
13 lat temu |
|
Ask Solem
|
be08d6c0de
Don't import ctypes types from winapi. Thanks to tigrang
|
13 lat temu |
|
Ask Solem
|
381dec4f44
Signal handler now raises if running without threads (while threads set a global should_stop flag)
|
13 lat temu |
|
Ask Solem
|
e6c9f14bb5
Adds TaskPool.readers/.writers instead of .eventmap
|
13 lat temu |
|
Ask Solem
|
144e352ee7
Adds celery.utils.threads.active_count
|
13 lat temu |
|
Ask Solem
|
1a984d973f
FORCE_EXECV is no longer enabled by default if using the eventloop (amqp/redis)
|
13 lat temu |
|
Ask Solem
|
0a4a092dff
eventloop improvements
|
13 lat temu |
|
Ask Solem
|
2d93e31360
event hub now supports writers
|
13 lat temu |
|
Ask Solem
|
7242818992
CELERY_BENCH now prints average and total time at shutdown
|
13 lat temu |
|
Ask Solem
|
b10d2336f6
celery.contrib.methods: Task decorator for methods
|
13 lat temu |
|
Ask Solem
|
cc1598eaaa
Fix for solo pool
|
13 lat temu |
|
Ask Solem
|
c9894a4836
Adds args, kwargs, internal to on_failure log extra data
|
13 lat temu |
|
Ask Solem
|
df92aef158
Disable mediator inside of eventloop
|
13 lat temu |
|
Ask Solem
|
16dcb2a192
Eventloop: Buffer when messages come close together
|
13 lat temu |
|
Ask Solem
|
7f2b9dad4c
Disable mediator thread when using eventloop
|
13 lat temu |
|
Ask Solem
|
22d11ddc82
Merge branch 'master' into hub_semaphore
|
13 lat temu |
|
Ask Solem
|
8092efe8f7
eventloop: AIO versiosn of multiprocessing Supervisor, and disable TaskHandler thread
|
13 lat temu |
|
Ask Solem
|
edf7c19e12
timer2: apply_interval no longer executes twice in the same time window
|
13 lat temu |
|
Ask Solem
|
7e43c5583d
Documentation now uses 'raise task.retry()'
|
13 lat temu |
|
Ask Solem
|
3d2101fbe2
Worker: Shutdown even if trying to restablish connection
|
13 lat temu |
|
Ask Solem
|
bb9c089a7a
Task.si(*a, **k) is now .subtask(a, k, immutable=True)
|
13 lat temu |
|
Ask Solem
|
141c232f75
Clarify the function of default queue, exchange and rkey settings. Closes #655
|
13 lat temu |
|
Ask Solem
|
c0ac1b763f
Only ever use one timer thread, and instead set the priorority for items.
|
13 lat temu |
