2d8f636 | Nicolas Dandrimont | 12 June 2017, 15:50:31 UTC | New upstream version 0.0.14 | 12 June 2017, 15:50:31 UTC |
7c1c041 | Nicolas Dandrimont | 12 June 2017, 15:49:58 UTC | listener: update for the new task-result event | 12 June 2017, 15:49:58 UTC |
d3abfa4 | Nicolas Dandrimont | 12 June 2017, 15:49:12 UTC | listener: derive the reliable events receiver from the base celery class | 12 June 2017, 15:49:12 UTC |
671a2c0 | Nicolas Dandrimont | 12 June 2017, 13:30:02 UTC | task: move run to run_task to allow overriding the default behavior of tasks This is an API break, but it's just a matter of renaming all existing tasks to run_task instead of run. Close T536 | 12 June 2017, 13:30:02 UTC |
07ea766 | Nicolas Dandrimont | 31 May 2017, 16:27:53 UTC | swh-worker-control: read the remote monotonic time to get task start times | 31 May 2017, 16:27:53 UTC |
c02757c | Nicolas Dandrimont | 31 May 2017, 16:27:00 UTC | celery_backend: add a remote-control command to get the monotonic clock | 31 May 2017, 16:27:00 UTC |
324a3cc | Nicolas Dandrimont | 31 May 2017, 15:49:06 UTC | bin/swh-worker-control: add command-line interface for worker remote control | 31 May 2017, 15:51:04 UTC |
4aaf546 | Nicolas Dandrimont | 07 April 2017, 09:57:50 UTC | New upstream version 0.0.13 | 07 April 2017, 09:57:50 UTC |
f758291 | Nicolas Dandrimont | 07 April 2017, 09:57:36 UTC | requirements-swh.txt: use proper syntax | 07 April 2017, 09:57:36 UTC |
a760866 | Nicolas Dandrimont | 07 April 2017, 09:53:08 UTC | d/copyright: cleanup | 07 April 2017, 09:53:08 UTC |
35997f8 | Nicolas Dandrimont | 07 April 2017, 09:52:27 UTC | celery_backend.config: use the JournalHandler for logging | 07 April 2017, 09:52:27 UTC |
debb3a6 | Nicolas Dandrimont | 09 March 2017, 10:12:45 UTC | New upstream version 0.0.12 | 09 March 2017, 10:12:45 UTC |
aaa5dfd | Nicolas Dandrimont | 09 March 2017, 10:12:09 UTC | celery_backend.config: only log to database if log_db is present | 09 March 2017, 10:12:09 UTC |
0767b4c | Antoine Pietri | 15 February 2017, 14:23:52 UTC | requirements.txt: ensure we use celery<4 (we don't support other versions for now) | 15 February 2017, 14:23:52 UTC |
7fbd090 | Nicolas Dandrimont | 14 February 2017, 18:49:34 UTC | New upstream version 0.0.11 | 14 February 2017, 18:49:34 UTC |
6192ac1 | Antoine R. Dumont (@ardumont) | 10 February 2017, 14:03:02 UTC | Add utils.get_task fn to simplify contextual task instance retrieval Permits to unify the task instance retrieval, which then permits to send messages to the associated task's queue. | 10 February 2017, 14:11:54 UTC |
1aedc67 | Antoine Pietri | 09 February 2017, 11:21:06 UTC | requirements: split internal and external requirements in two separate files | 09 February 2017, 13:32:06 UTC |
d65742e | Antoine Pietri | 09 February 2017, 11:19:06 UTC | celery_backend: pep8: fix missing blank lines | 09 February 2017, 11:21:23 UTC |
05f41c2 | Nicolas Dandrimont | 21 October 2016, 14:09:11 UTC | sql: fix default_interval selection for new tasks | 21 October 2016, 14:09:11 UTC |
faa3439 | Nicolas Dandrimont | 20 October 2016, 15:20:16 UTC | New upstream version 0.0.10 | 20 October 2016, 15:20:16 UTC |
b048926 | Nicolas Dandrimont | 20 October 2016, 14:02:57 UTC | backend: the status of a task is task.status, not task.task_status... | 20 October 2016, 14:02:57 UTC |
da7b1b7 | Nicolas Dandrimont | 19 October 2016, 13:39:05 UTC | backend: allow disabling tasks | 19 October 2016, 13:39:05 UTC |
0fb8eef | Antoine R. Dumont (@ardumont) | 23 August 2016, 16:44:15 UTC | Fix docstring typo | 05 September 2016, 12:27:28 UTC |
9fb45f5 | Nicolas Dandrimont | 02 September 2016, 15:09:17 UTC | New upstream version 0.0.9 | 02 September 2016, 15:09:17 UTC |
51cb666 | Nicolas Dandrimont | 01 September 2016, 15:23:15 UTC | celery_backend.config: add SWH_WORKER_INSTANCE environment variable This allows to run several workers with different configuration files. | 01 September 2016, 15:23:15 UTC |
cf55f87 | Antoine R. Dumont (@ardumont) | 01 July 2016, 14:42:45 UTC | New upstream version 0.0.7 | 01 July 2016, 14:42:45 UTC |
811718b | Antoine R. Dumont (@ardumont) | 01 July 2016, 13:29:51 UTC | Just use default date of insertion to sort and reschedule job | 01 July 2016, 13:29:51 UTC |
ae202d1 | Antoine R. Dumont (@ardumont) | 29 June 2016, 17:54:18 UTC | Permit to schedule oneshot tasks | 29 June 2016, 17:54:55 UTC |
596bfda | Nicolas Dandrimont | 24 February 2016, 17:46:57 UTC | New upstream version 0.0.6 | 24 February 2016, 17:46:57 UTC |
dced5d5 | Nicolas Dandrimont | 24 February 2016, 15:36:52 UTC | celery_backend.config: Put pickle last in the accepted encodings | 24 February 2016, 15:36:52 UTC |
7d6e331 | Nicolas Dandrimont | 24 February 2016, 15:36:02 UTC | backend: allow for mass-scheduling of task runs This allows the runner to be (~10 times) more efficient when running tasks | 24 February 2016, 15:36:02 UTC |
05c5f9d | Nicolas Dandrimont | 24 February 2016, 11:13:38 UTC | New upstream version 0.0.5 | 24 February 2016, 11:13:38 UTC |
15c3d8f | Nicolas Dandrimont | 24 February 2016, 11:10:51 UTC | backend: use copy for mass-scheduling of tasks | 24 February 2016, 11:10:51 UTC |
ec0a71c | Nicolas Dandrimont | 23 February 2016, 16:46:04 UTC | New upstream version 0.0.4 | 23 February 2016, 16:46:04 UTC |
4886edf | Nicolas Dandrimont | 23 February 2016, 16:08:46 UTC | Add cli to setup.py | 23 February 2016, 16:08:46 UTC |
f390dec | Nicolas Dandrimont | 23 February 2016, 16:05:27 UTC | cli: New command-line interface based on Click | 23 February 2016, 16:06:13 UTC |
77bcb2a | Nicolas Dandrimont | 23 February 2016, 16:05:44 UTC | backend: allow overriding the config at instantiation | 23 February 2016, 16:06:13 UTC |
35edc1a | Nicolas Dandrimont | 23 February 2016, 16:04:33 UTC | backend: use arrow instead of dateutil | 23 February 2016, 16:04:33 UTC |
e9c4442 | Nicolas Dandrimont | 23 February 2016, 11:07:03 UTC | d/copyright: update for Celery license | 23 February 2016, 11:07:36 UTC |
d89860f | Nicolas Dandrimont | 23 February 2016, 10:58:01 UTC | Add missing Celery license file | 23 February 2016, 10:58:01 UTC |
314e4dd | Nicolas Dandrimont | 23 February 2016, 10:56:41 UTC | celery_backend.listener: Remove useless arguments to event functions | 23 February 2016, 10:56:41 UTC |
606fd39 | Nicolas Dandrimont | 23 February 2016, 10:56:06 UTC | celery_backend.listener: force sending the events at startup | 23 February 2016, 10:56:06 UTC |
a3dbeeb | Nicolas Dandrimont | 22 February 2016, 14:14:28 UTC | New upstream version 0.0.3 | 22 February 2016, 14:14:28 UTC |
e88c731 | Nicolas Dandrimont | 22 February 2016, 14:07:52 UTC | celery_backend.listener: make the event listener reliable We reimplement the event listener using kombu directly instead of Celery, which allows us to create persistent queues and manually ack the messages once we have received them. We bundle messages by packets of 1000 or 1/second when sending them to the database. We only ack the messages once the database transcation has ended. | 22 February 2016, 14:07:52 UTC |
c4e1b63 | Nicolas Dandrimont | 22 February 2016, 14:06:55 UTC | backend: implement the timestamp argument for the task_run functions | 22 February 2016, 14:07:22 UTC |
911df24 | Nicolas Dandrimont | 22 February 2016, 14:06:03 UTC | celery_backend.runner: only commit once per packet | 22 February 2016, 14:06:03 UTC |
315d33b | Nicolas Dandrimont | 19 February 2016, 17:50:47 UTC | New upstream version 0.0.2 | 19 February 2016, 17:50:47 UTC |
f3c8cad | Nicolas Dandrimont | 19 February 2016, 17:49:45 UTC | celery: move to celery_backend to avoid clashing with system celery | 19 February 2016, 17:50:40 UTC |
0df7211 | Nicolas Dandrimont | 19 February 2016, 17:46:40 UTC | d/control: add missing B-D on Celery | 19 February 2016, 17:46:40 UTC |
d389ce2 | Nicolas Dandrimont | 19 February 2016, 17:35:27 UTC | setup.py: install all packages | 19 February 2016, 17:43:53 UTC |
06d7095 | Nicolas Dandrimont | 19 February 2016, 17:34:53 UTC | tests: Add basic tests for task | 19 February 2016, 17:34:53 UTC |
482d414 | Nicolas Dandrimont | 19 February 2016, 17:27:03 UTC | schema: replace the eventful boolean with a task run status | 19 February 2016, 17:27:03 UTC |
655a9d0 | Nicolas Dandrimont | 19 February 2016, 11:47:49 UTC | scheduler.celery: add listener for events and runner to generate tasks | 19 February 2016, 11:47:49 UTC |
8d512e3 | Nicolas Dandrimont | 18 February 2016, 16:47:49 UTC | backend: wrap all the DB methods | 18 February 2016, 16:47:49 UTC |
c70627e | Nicolas Dandrimont | 16 February 2016, 18:24:55 UTC | backend: initialize a simple backend for swh.scheduler | 16 February 2016, 18:24:55 UTC |
196e506 | Nicolas Dandrimont | 16 February 2016, 18:24:25 UTC | celery: move worker to a "celery.config" class, add listener | 16 February 2016, 18:24:25 UTC |
efc7ff8 | Nicolas Dandrimont | 16 February 2016, 10:27:40 UTC | sql: update testdata and functions for new schema | 16 February 2016, 10:27:40 UTC |
86f5e28 | Nicolas Dandrimont | 16 February 2016, 09:51:17 UTC | sql/schema: Clean up formatting | 16 February 2016, 09:51:17 UTC |
8ba5475 | Nicolas Dandrimont | 15 February 2016, 15:24:51 UTC | sql: add schema for swh-scheduler, and some test data | 15 February 2016, 15:24:51 UTC |
7048ef4 | Nicolas Dandrimont | 15 February 2016, 10:07:30 UTC | Import upstream version 0.0.1 | 15 February 2016, 10:07:30 UTC |
a1b0a98 | Nicolas Dandrimont | 15 February 2016, 10:07:20 UTC | d/rules: test proper module | 15 February 2016, 10:07:20 UTC |
533dece | Nicolas Dandrimont | 15 February 2016, 10:06:55 UTC | .gitignore: ignore vcversioner file | 15 February 2016, 10:06:55 UTC |
759c5f1 | Nicolas Dandrimont | 15 February 2016, 10:01:52 UTC | Move worker and task setup to swh.scheduler | 15 February 2016, 10:01:52 UTC |
efd4735 | Nicolas Dandrimont | 15 February 2016, 09:38:13 UTC | Update template data for swh.scheduler | 15 February 2016, 09:38:13 UTC |
2083b9a | Nicolas Dandrimont | 15 February 2016, 09:34:23 UTC | import template from swh-py-template (init-py-repo) | 15 February 2016, 09:34:23 UTC |