We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 05f0ac2 commit 92ad273Copy full SHA for 92ad273
libs/executors/garf/executors/entrypoints/cli.py
@@ -86,7 +86,10 @@ def main():
86
wf_parent = pathlib.Path.cwd() / pathlib.Path(workflow_file).parent
87
execution_workflow = workflow.Workflow.from_file(workflow_file)
88
for i, step in enumerate(execution_workflow.steps, 1):
89
- with tracer.start_as_current_span(f'{i}-{step.fetcher}'):
+ step_span_name = f'{i}-{step.fetcher}'
90
+ if step.alias:
91
+ step_span_name = f'{step_span_name}-{step.alias}'
92
+ with tracer.start_as_current_span(step_span_name):
93
query_executor = garf.executors.setup_executor(
94
source=step.fetcher,
95
fetcher_parameters=step.fetcher_parameters,
0 commit comments