Actually, my job has multiple streaming tasks running independently. I would like to make the whole job stop if one of the streaming tasks fails.

For example, one of the tasks failed after 8 minutes of execution, but the others continued running for 35 hours until I found and canceled them. I would the job to fail if any task fails.