( ctx context.Context, id toolspkg.ToolID, scope toolspkg.Scope, taskID string, runID string, )
| 4449 | } |
| 4450 | |
| 4451 | func (n *daemonNativeTools) nativeTaskBlockActor( |
| 4452 | ctx context.Context, |
| 4453 | id toolspkg.ToolID, |
| 4454 | scope toolspkg.Scope, |
| 4455 | taskID string, |
| 4456 | runID string, |
| 4457 | ) (taskpkg.ActorContext, string, string, error) { |
| 4458 | if strings.TrimSpace(scope.SessionID) == "" || scope.Operator { |
| 4459 | actor, err := nativeOperatorActorContext(scope) |
| 4460 | if err != nil { |
| 4461 | return taskpkg.ActorContext{}, "", "", err |
| 4462 | } |
| 4463 | return actor, strings.TrimSpace(runID), "", nil |
| 4464 | } |
| 4465 | actor, handle, err := n.nativeTaskLeaseActor(ctx, id, scope, taskID, runID) |
| 4466 | if err != nil { |
| 4467 | return taskpkg.ActorContext{}, "", "", err |
| 4468 | } |
| 4469 | return actor, handle.RunID, handle.ClaimToken, nil |
| 4470 | } |
| 4471 | |
| 4472 | func (n *daemonNativeTools) nativeTaskClearActor( |
| 4473 | ctx context.Context, |
no test coverage detected