Skip to content

Fix Concurrency & Spans#613

Merged
kraftp merged 4 commits intomainfrom
kraftp/fixes
Mar 11, 2026
Merged

Fix Concurrency & Spans#613
kraftp merged 4 commits intomainfrom
kraftp/fixes

Conversation

@kraftp
Copy link
Copy Markdown
Member

@kraftp kraftp commented Mar 11, 2026

@dosubot
Copy link
Copy Markdown

dosubot bot commented Mar 11, 2026

Documentation Updates

1 document(s) were updated by changes in this PR:

System Database Schema
View Changes
@@ -468,7 +468,7 @@
 
 ### Step Results
 
-Individual operation results are recorded by [`record_operation_result`](https://github.com/dbos-inc/dbos-transact-py/blob/12049d833dddbcaaea18d921149e2c33aad37ecf/dbos/_sys_db.py#L1378-L1388), which calls [`_record_operation_result_txn`](https://github.com/dbos-inc/dbos-transact-py/blob/12049d833dddbcaaea18d921149e2c33aad37ecf/dbos/_sys_db.py#L1311-L1377) to insert into `operation_outputs` using INSERT ... ON CONFLICT DO NOTHING.
+Individual operation results are recorded by [`record_operation_result`](https://github.com/dbos-inc/dbos-transact-py/blob/12049d833dddbcaaea18d921149e2c33aad37ecf/dbos/_sys_db.py#L1378-L1388), which calls [`_record_operation_result_txn`](https://github.com/dbos-inc/dbos-transact-py/blob/12049d833dddbcaaea18d921149e2c33aad37ecf/dbos/_sys_db.py#L1311-L1377) to insert into `operation_outputs` using INSERT ... ON CONFLICT DO UPDATE. When a conflict occurs on the composite primary key `(workflow_uuid, function_id)`, the system updates the `completed_at_epoch_ms` timestamp to ensure the completion time is properly recorded even when the same operation result is inserted multiple times due to retries or concurrent workflow execution.
 
 ### Queue Management
 

How did I do? Any feedback?  Join Discord

@kraftp kraftp merged commit d69612c into main Mar 11, 2026
10 checks passed
@kraftp kraftp deleted the kraftp/fixes branch March 11, 2026 22:01
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Emit queue name with OTEL logs and traces

3 participants