Skip to content

Commit d6d0d75

Browse files
chore(executors): add logging to worklow runner
1 parent adff013 commit d6d0d75

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

libs/executors/garf/executors/workflows/workflow_runner.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,11 +69,15 @@ def run(
6969
) -> list[str]:
7070
reader_client = reader.create_reader('file')
7171
execution_results = []
72+
logger.info('Starting Garf Workflow...')
7273
for i, step in enumerate(self.workflow.steps, 1):
7374
step_name = f'{i}-{step.fetcher}'
7475
if step.alias:
7576
step_name = f'{step_name}-{step.alias}'
7677
with tracer.start_as_current_span(step_name):
78+
logger.info(
79+
'Running step %d, fetcher: %s, alias: %s', i, step.fetcher, step.alias
80+
)
7781
query_executor = setup.setup_executor(
7882
source=step.fetcher,
7983
fetcher_parameters=step.fetcher_parameters,

0 commit comments

Comments
 (0)