Atomic stream writes logic

[maxdml]

=== Failed
=== FAIL: dbos TestStreams/Async/StreamWorkflowRecovery (0.02s)
time=2026-02-03T23:51:01.995Z level=WARN msg="Workflow ID conflict detected. Waiting for existing workflow to complete" workflow_id=ea050c3f-b612-406b-b4bb-ca78120af11c
    workflows_test.go:5600: 
        	Error Trace:	/home/runner/work/dbos-transact-golang/dbos-transact-golang/dbos/workflows_test.go:5600
        	Error:      	Received unexpected error:
        	            	failed to insert stream entry: ERROR: duplicate key value violates unique constraint "streams_pkey" (SQLSTATE 23505)
        	Test:       	TestStreams/Async/StreamWorkflowRecovery
        	Messages:   	failed to get result from original workflow
        --- FAIL: TestStreams/Async/StreamWorkflowRecovery (0.02s)

=== FAIL: dbos TestStreams/Async (1.08s)
    --- FAIL: TestStreams/Async (1.08s)

=== FAIL: dbos TestStreams (3.34s)
time=2026-02-03T23:51:00.752Z level=INFO msg="Initializing DBOS context" app_name=test-app dbos_version=(devel)
time=2026-02-03T23:51:00.753Z level=INFO msg="Connecting to system database" database_url="***localhost:5432/dbos?sslmode=disable" schema=dbos
time=2026-02-03T23:51:00.852Z level=INFO msg="DBOS launched" app_version=7a0599556883dc56c632424c2ec7b8f719924bbd7769afdb8cc8d458e8831659 executor_id=local