molecule-ai/molecule-core
41
0
Fork 2
Code Issues 47 Pull Requests 1 Actions 715 Packages Projects Releases Wiki Activity

fix(handlers): update executeDelegation integration test calls (staging PR #916 follow-up) #945

Merged
devops-engineer merged 1 commits from fix/staging-integration-test-ctx into staging 2026-05-14 03:56:14 +00:00
Conversation 18 Commits 1 Files Changed 1 +10 -5
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
workspace-server/internal/handlers/delegation_executor_integration_test.go
View File

@ -303,7 +303,8 @@ func TestIntegration_ExecuteDelegation_DeliveryConfirmedProxyError_TreatsAsSucce
start := time.Now()
runWithTimeout(t, 30*time.Second, func(ctx context.Context) {
dh.executeDelegation(ctx, testSourceID, testTargetID, testDelegationID, a2aBody)
_ = ctx // ctx unused: executeDelegation manages its own 30-min timeout internally
dh.executeDelegation(testSourceID, testTargetID, testDelegationID, a2aBody)
})
t.Logf("executeDelegation took %v", time.Since(start))
@ -355,7 +356,8 @@ func TestIntegration_ExecuteDelegation_ProxyErrorNon2xx_RemainsFailed(t *testing
})
start := time.Now()
runWithTimeout(t, 30*time.Second, func(ctx context.Context) {
dh.executeDelegation(ctx, testSourceID, testTargetID, testDelegationID, a2aBody)
_ = ctx // ctx unused: executeDelegation manages its own 30-min timeout internally
dh.executeDelegation(testSourceID, testTargetID, testDelegationID, a2aBody)
})
t.Logf("executeDelegation took %v", time.Since(start))
@ -404,7 +406,8 @@ func TestIntegration_ExecuteDelegation_ProxyErrorEmptyBody_RemainsFailed(t *test
})
start := time.Now()
runWithTimeout(t, 30*time.Second, func(ctx context.Context) {
dh.executeDelegation(ctx, testSourceID, testTargetID, testDelegationID, a2aBody)
_ = ctx // ctx unused: executeDelegation manages its own 30-min timeout internally
dh.executeDelegation(testSourceID, testTargetID, testDelegationID, a2aBody)
})
t.Logf("executeDelegation took %v", time.Since(start))
@ -452,7 +455,8 @@ func TestIntegration_ExecuteDelegation_CleanProxyResponse_Unchanged(t *testing.T
})
start := time.Now()
runWithTimeout(t, 30*time.Second, func(ctx context.Context) {
dh.executeDelegation(ctx, testSourceID, testTargetID, testDelegationID, a2aBody)
_ = ctx // ctx unused: executeDelegation manages its own 30-min timeout internally
dh.executeDelegation(testSourceID, testTargetID, testDelegationID, a2aBody)
})
t.Logf("executeDelegation took %v", time.Since(start))
@ -497,7 +501,8 @@ func TestIntegration_ExecuteDelegation_RedisDown_FallsBackToDB(t *testing.T) {
})
start := time.Now()
runWithTimeout(t, 30*time.Second, func(ctx context.Context) {
dh.executeDelegation(ctx, testSourceID, testTargetID, testDelegationID, a2aBody)
_ = ctx // ctx unused: executeDelegation manages its own 30-min timeout internally
dh.executeDelegation(testSourceID, testTargetID, testDelegationID, a2aBody)
})
t.Logf("executeDelegation took %v", time.Since(start))