Method BreakLockJobIsQueued

database/common/store.go:129–129 · view source on GitHub ↗

(ctx context.Context, jobID int64)

Source from the content-addressed store, hash-verified

127	UnlockJob(ctx context.Context, jobID int64, entityID string) error
128	LockJob(ctx context.Context, jobID int64, entityID string) error
129	BreakLockJobIsQueued(ctx context.Context, jobID int64) error
130
131	DeleteInactionableJobs(ctx context.Context, olderThan time.Duration) error
132	}

HandleWorkflowJobMethod · 0.65

TestJobWatcherMethod · 0.65

sqlDatabasedatabase/sql/sql.go

Storedatabase/common/mocks/Store.go

Store_Expecterdatabase/common/mocks/Store.go

no outgoing calls

TestJobWatcherMethod · 0.52