hotkit / django-async Goto Github PK

The flush_queue management command no longer reports any command line options, and options like -w no longer work. Probably the health management command is similarly affected.

Installing from pip and running setup.py gives me the same error

see necessary changes here:
dcollinsn@0e464ed

Hi, The current implementation which (worker) - outof (total workers) picks jobs by partitioning the id space. If for whatever reason one of the worker is stuck processing a job, all the current and future jobs assigned to this worker will stall. Is there any plan (or ideas) to make this more fault tolerant? i.e. a worker can pick any job that is scheduled to run now (irrespective of the id of the job)? This will also make adding and removing worker much easier.

The namespace async is no longer valid as it's now a reserved keyword in python 3.6+.

Installer needs to reserve a new namespace.

if the args contain some non ascii chars sometimes flush-queue stops with:

  File "/....../lib/python3.4/site-packages/async/management/commands/flush_queue.py", line 63, in run
    print ("%s: %s" % (job.id, job))
UnicodeEncodeError: 'ascii' codec can't encode character '\xe9' in position 137: ordinal not in range(128)

the args in the above failure where:
["fiche-de-suivi-mensuel-collines", "ben", {"query": "l\u00e9a", "group": null, "status": null}, {"host": "ben.mdca.wfp.org", "is_secure": false}, false, false]

the job finished but was never marked completed as it broke on print job