Failed tasks and Chain

[nvictor]

I must be doing something wrong. When a task within a chain fails, the next one is still queued. Not the behavior I was expecting since tasks depend on successful previous tasks in my situation.

I am wondering if that's how it's supposed to be, since no one else seems to have this issue?

I have this configuration

Q_CLUSTER = {
    'name': 'cluster-1',
    'label': 'DjangoQ Tasks',
    'timeout': 2*60*60,
    'retry': 2.5*60*60,
    'orm': 'default'
}

The tasks are created and run using

ch = Chain()
...
ch.append(full_python_path(context, task), context=context, ...)
...
ch.run()

[nvictor]

I may have answered my own question. I am going to close this issue and do some more testing on my side.

For anyone reading: seems the sync option (I saw it in the docs but I was left to believe it was just for testing) and a container for my chains would work.

The current structure I am testing is

# class ChainList(list):
#     def run(self):
#        for ch in self:
#            ch.run()
chl = ChainList()
...
ch = Chain(sync=True)
...
ch.append(...)
...
chl.append(ch)
...
# finally
chl.run()

[nvictor]

Nope. Still queueing tasks one after a failed one even with sync=True...