Hello. How can I get tags and run id of current Job from Op?

Hi @Vlad Efanov, when defining an Op, it gets a

context

(type:

OpExecutionContext

) Then:

@op
def my_op(context: OpExecutionContext) -> None:
    run_id = context.run_id
    job_tags = context.pipeline_run.tags

Thanks. It works