Join Slack

Hiya, is it possible to use a string concatenation of a task result as an input parameter to a downs...

# ask-community

Oliver Mannion

07/01/2022, 8:02 AM

Hiya, is it possible to use a string concatenation of a task result as an input parameter to a downstream task? 🧵

Oliver Mannion

07/01/2022, 8:02 AM

Copy code

@task
def determine_batch_start_and_end() -> Tuple[str, str]:
    now = pendulum.now(tz="UTC")
    batch_start, batch_end = get_last_hour(now)
    return (batch_start, batch_end)

def build_flow(flow_name: str) -> Flow:
    with Flow(flow_name) as flow:

        batch_start, batch_end = determine_batch_start_and_end()

        create_flow_run(
            flow_id=settings.flow_id,
            run_name=f"br_{str(batch_start)}"
        )

    return flow

Oliver Mannion

07/01/2022, 8:03 AM

I'd like

run_name

to be something like

br_2022-07-01 07:00:00

but it ends up being

br_<Task: determine_batch_start_and_end[0]>

Anna Geller

07/01/2022, 11:26 AM

you would need to solve it using separate task as described here https://discourse.prefect.io/t/how-to-dynamically-change-the-run-name-in-the-create-flow-run-task/97#solution-1

🙏 1

Anna Geller

07/01/2022, 11:27 AM

or here https://discourse.prefect.io/t/how-to-customize-how-the-name-of-a-task-triggering-a-chi[…]-how-to-override-the-default-task-name-create-flow-run/476

gratitude thank you 1

3 Views

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.