Gustavo Zuniga Goni
09/12/2023, 11:04 PMprefect deployment build flujo_llamaOtro.py:flujo_llamaOtro --name flujo_llamaOtro
prefect deployment apply flujo_llamaOtro-deployment.yaml
But I want it to run immediately after I deploy it and not have to enter these commands manually:
prefect agent start -q ‘default’
prefect deployment run 'flujo_llamaOtro/flujo_llamaOtro'
Can somebody help me?
from prefect import flow, task,
from prefect.deployments import run_deployment
@task
def tarea_a(valor: int):
valor = valor +700
run_deployment("flujo_quesellama/flujo_quesellama")
return valor
@task
def tarea_b(valor: int):
valor = valor + 1
return valor
@flow(name="flujo_llamaOtro",description="Este Flujo sera el que llama a otro que se ejecute",log_prints=True)
def flujo_llamaOtro(valor: int = 111 ):
rtarea_a = tarea_a(valor)
print(rtarea_a)
rtarea_b = tarea_b(rtarea_a)
print(rtarea_b)
Nate
09/12/2023, 11:16 PMfrom prefect import flow, task,
from prefect.deployments import run_deployment
@task
def tarea_a(valor: int):
valor = valor +700
run_deployment("flujo_quesellama/flujo_quesellama")
return valor
@task
def tarea_b(valor: int):
valor = valor + 1
return valor
@flow(name="flujo_llamaOtro",description="Este Flujo sera el que llama a otro que se ejecute",log_prints=True)
def flujo_llamaOtro(valor: int = 111 ):
rtarea_a = tarea_a(valor)
print(rtarea_a)
rtarea_b = tarea_b(rtarea_a)
print(rtarea_b)
if __name__ == "__main__":
flujo_llamaOtro.serve(name=__file__)
if __name__ == "__main__":
flujo_llamaOtro.serve(name=__file__)
when you do python my_flow.py
- the flow's serve
command will create a deployment and it will be ready to trigger via CLI, UI, or API otherwiseGustavo Zuniga Goni
09/12/2023, 11:24 PMNate
09/12/2023, 11:28 PMif __name__ == "__main__":
flujo_llamaOtro()
Gustavo Zuniga Goni
09/12/2023, 11:36 PM