luigi icon indicating copy to clipboard operation
luigi copied to clipboard

Sequential processing of a specific task with resouces:1 seems to be not working

Open joshy opened this issue 6 months ago • 0 comments

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

joshy avatar Aug 13 '24 13:08 joshy