@@ -296,7 +296,7 @@ def post_all_metrics(self) -> None:
296296 def _upload_workflow_metrics (self , workflow_data : Dict [str , Any ], jobs_data : Dict [str , Any ]) -> None :
297297 """Internal method to upload workflow metrics"""
298298 db_data = {}
299- db_data [FIELD_ID ] = f"real-workflow-{ self .run_id } _ { self . repo . replace ( '/' , '_' ) } "
299+ db_data [FIELD_ID ] = f"real-workflow-{ self .run_id } "
300300
301301 # Schema fields
302302 db_data [FIELD_WORKFLOW_ID ] = str (self .run_id )
@@ -365,7 +365,7 @@ def post_workflow_metrics(self) -> Optional[Dict[str, Any]]:
365365
366366 # Extract workflow metrics using standardized functions
367367 db_data = {}
368- db_data [FIELD_ID ] = f"real-workflow-{ self .run_id } _ { self . repo . replace ( '/' , '_' ) } "
368+ db_data [FIELD_ID ] = f"real-workflow-{ self .run_id } "
369369
370370 # Schema fields
371371 db_data [FIELD_WORKFLOW_ID ] = str (self .run_id )
@@ -438,7 +438,7 @@ def _upload_single_job_metrics(self, job_data: Dict[str, Any]) -> None:
438438 job_id = job_data ['id' ]
439439 job_name = job_data ['name' ]
440440
441- db_data [FIELD_ID ] = f"real-workflow -{ job_id } _ { self . repo . replace ( '/' , '_' ) } "
441+ db_data [FIELD_ID ] = f"real-job -{ job_id } "
442442
443443 # Schema fields
444444 db_data [FIELD_JOB_ID ] = str (job_id )
@@ -516,7 +516,7 @@ def _upload_single_step_metrics(self, step_data: Dict[str, Any], job_data: Dict[
516516
517517 # Create unique step ID and use standardized ID generation
518518 step_id = f"{ job_id } _{ step_number } "
519- db_data [FIELD_ID ] = f"real-workflow-step_ { step_id } _ { self . repo . replace ( '/' , '_' ) } "
519+ db_data [FIELD_ID ] = f"real-step- { step_id } "
520520
521521 # Schema-compliant fields
522522 db_data [FIELD_STEP_ID ] = str (step_id )
0 commit comments