kestra_workflow_pandas_data_processing_with_output_variable.py

1import pandas as pd
2import numpy as np
3
4# Sample data generation
5data = {
6    'A': np.random.rand(5),
7    'B': np.random.rand(5)
8}
9
10df = pd.DataFrame(data)
11
12# Simple processing
13df['C'] = df['A'] + df['B']
14
15print(df)
16
17# Kestra-specific output (optional, used to pass data back to the flow)
18from kestra import Kestra
19Kestra.outputs({'mean_c': df['C'].mean()})