diff --git a/cloud_pipelines_backend/api_server_sql.py b/cloud_pipelines_backend/api_server_sql.py index 07eb11b..159ae9c 100644 --- a/cloud_pipelines_backend/api_server_sql.py +++ b/cloud_pipelines_backend/api_server_sql.py @@ -108,6 +108,11 @@ def create( }, ) session.add(pipeline_run) + for key, value in (annotations or {}).items(): + pipeline_run_annotation = bts.PipelineRunAnnotation( + pipeline_run_id=key, key=key, value=value + ) + session.add(pipeline_run_annotation) session.commit() session.refresh(pipeline_run)