luigi
luigi copied to clipboard
Sequential processing of a specific task with resouces:1 seems to be not working
Hi
maybe I am doing something wrong but I have the following situation: I have one specific task named PrefetchTask
which can not run in parallel. To achieve this I have introduced a resource like resources = {'prefetch': 1}
in the class PrefetchTask
. In the luigi configuration at /etc/luigi/luigi.cfg
I have added the following section:
[resources]
prefetch=1
If I then submit two tasks, the first one is status running
the second one is status pending
because of 1 was not granted run persmission by the scheduler
. The second task is never run and after some time it is in status done
without creating the output file. I was expecting it to be scheduled after task one is finished and the run. Is it working as intented?
Thanks for your help,
Joshy
PS: Is there a better way to achieve what I want?
PPS: Running luigi version: 3.5.1 with python 3.11.8