Hi!
I would need help with the following question:
Is there a way to stop running a pipeline with a sensor?
I need to be able to stop the execution of a pipe based on the value of an external factor.
Example:
@solid
def task1():
number = 1
return number
@solid
def task2(number):
number2 = number + 1
return number2
@pipeline
def my_number_pipeline():
task2(task1())
''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
external_factor = 0
if external_factor > 0
stop pipeline
'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
Thanks!!!