Jonas Krüger Svensson
Jonas Krüger Svensson
I'll have to look into this further tomorrow, as I have never had the need to cancel jobs myself. > Running job.abort() with or without timemout seems to have no...
Hey, apologize for the lack of response. I haven't forgot, just not found the time. I've got off on Friday, and I'll use that day for open source/personal projects and...
Hi again @gerazenobi 😊 First, in case someone else reads this issue at a later point: The `abort()` function requires the `allow_abort_jobs` flag has been set on the worker: >...
Using your example from the first post results in this output: ``` queued jobs 10 job info: JobDef(function='compute', args=(), kwargs={}, job_try=None, enqueue_time=datetime.datetime(2023, 5, 25, 7, 14, 55, 350000, tzinfo=datetime.timezone.utc), score=1684998895350)...
Aha, I see, with the new example there's something iffy going on. With the job: ```python async def compute(ctx): print(f'starting job {ctx}') await asyncio.sleep(30) print('slept') return ctx["job_id"] ``` Then finding...
Arq is used in production at a big scale. It is stable and production ready. Please let me know if there’s something specific you really need to be merged (and...
This would essentially only be a matter of which queue to _pick_ from first, not which task to process, right? So if your worker is configured to `max_jobs=10` jobs and...
Hi, please see https://github.com/samuelcolvin/arq/issues/372#issuecomment-1342497550.
Aha, I can fix that.
Cheers Samuel, I'll look over the errors when I find time. Probably next week or so, I'm gone for a work trip. If you want to fork my fork and...