Skip to content

Commit 3bef95c

Browse files
chore(executors): include alias into a span when running CLI
1 parent 05f0ac2 commit 3bef95c

File tree

1 file changed

+4
-1
lines changed
  • libs/executors/garf/executors/entrypoints

1 file changed

+4
-1
lines changed

libs/executors/garf/executors/entrypoints/cli.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,10 @@ def main():
8686
wf_parent = pathlib.Path.cwd() / pathlib.Path(workflow_file).parent
8787
execution_workflow = workflow.Workflow.from_file(workflow_file)
8888
for i, step in enumerate(execution_workflow.steps, 1):
89-
with tracer.start_as_current_span(f'{i}-{step.fetcher}'):
89+
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):
9093
query_executor = garf.executors.setup_executor(
9194
source=step.fetcher,
9295
fetcher_parameters=step.fetcher_parameters,

0 commit comments

Comments
 (0)