Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commitf527bc2

Browse files
chore(coderd/database): support status for a task
1 parente53bc24 commitf527bc2

File tree

14 files changed

+985
-119
lines changed

14 files changed

+985
-119
lines changed

‎coderd/database/check_constraint.go‎

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more aboutcustomizing how changed files appear on GitHub.

‎coderd/database/dbauthz/dbauthz.go‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2781,6 +2781,10 @@ func (q *querier) GetTailnetTunnelPeerIDs(ctx context.Context, srcID uuid.UUID)
27812781
returnq.db.GetTailnetTunnelPeerIDs(ctx,srcID)
27822782
}
27832783

2784+
func (q*querier)GetTaskByID(ctx context.Context,id uuid.UUID) (database.Task,error) {
2785+
panic("not implemented")
2786+
}
2787+
27842788
func (q*querier)GetTelemetryItem(ctx context.Context,keystring) (database.TelemetryItem,error) {
27852789
iferr:=q.authorizeContext(ctx,policy.ActionRead,rbac.ResourceSystem);err!=nil {
27862790
return database.TelemetryItem{},err
@@ -3978,6 +3982,14 @@ func (q *querier) InsertReplica(ctx context.Context, arg database.InsertReplicaP
39783982
returnq.db.InsertReplica(ctx,arg)
39793983
}
39803984

3985+
func (q*querier)InsertTask(ctx context.Context,arg database.InsertTaskParams) (database.TaskTable,error) {
3986+
panic("not implemented")
3987+
}
3988+
3989+
func (q*querier)InsertTaskWorkspaceApp(ctx context.Context,arg database.InsertTaskWorkspaceAppParams) (database.TaskWorkspaceApp,error) {
3990+
panic("not implemented")
3991+
}
3992+
39813993
func (q*querier)InsertTelemetryItemIfNotExists(ctx context.Context,arg database.InsertTelemetryItemIfNotExistsParams)error {
39823994
iferr:=q.authorizeContext(ctx,policy.ActionCreate,rbac.ResourceSystem);err!=nil {
39833995
returnerr

‎coderd/database/dbgen/dbgen.go‎

Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ import (
2727
"github.com/coder/coder/v2/coderd/database/provisionerjobs"
2828
"github.com/coder/coder/v2/coderd/database/pubsub"
2929
"github.com/coder/coder/v2/coderd/rbac"
30+
"github.com/coder/coder/v2/coderd/taskname"
3031
"github.com/coder/coder/v2/codersdk"
3132
"github.com/coder/coder/v2/cryptorand"
3233
"github.com/coder/coder/v2/provisionerd/proto"
@@ -1470,6 +1471,43 @@ func ClaimPrebuild(
14701471
returnclaimedWorkspace
14711472
}
14721473

1474+
funcTask(t testing.TB,db database.Store,orig database.TaskTable) database.TaskTable {
1475+
t.Helper()
1476+
1477+
parameters:=orig.TemplateParameters
1478+
ifparameters==nil {
1479+
parameters=json.RawMessage([]byte("{}"))
1480+
}
1481+
1482+
task,err:=db.InsertTask(genCtx, database.InsertTaskParams{
1483+
OrganizationID:orig.OrganizationID,
1484+
OwnerID:orig.OwnerID,
1485+
Name:takeFirst(orig.Name,taskname.GenerateFallback()),
1486+
WorkspaceID:orig.WorkspaceID,
1487+
TemplateVersionID:orig.TemplateVersionID,
1488+
TemplateParameters:parameters,
1489+
Prompt:orig.Prompt,
1490+
CreatedAt:takeFirst(orig.CreatedAt,dbtime.Now()),
1491+
})
1492+
require.NoError(t,err,"failed to insert task")
1493+
1494+
returntask
1495+
}
1496+
1497+
funcTaskWorkspaceApp(t testing.TB,db database.Store,orig database.TaskWorkspaceApp) database.TaskWorkspaceApp {
1498+
t.Helper()
1499+
1500+
app,err:=db.InsertTaskWorkspaceApp(genCtx, database.InsertTaskWorkspaceAppParams{
1501+
TaskID:orig.TaskID,
1502+
WorkspaceBuildID:orig.WorkspaceBuildID,
1503+
WorkspaceAgentID:orig.WorkspaceAgentID,
1504+
WorkspaceAppID:orig.WorkspaceAppID,
1505+
})
1506+
require.NoError(t,err,"failed to insert task workspace app")
1507+
1508+
returnapp
1509+
}
1510+
14731511
funcprovisionerJobTiming(t testing.TB,db database.Store,seed database.ProvisionerJobTiming) database.ProvisionerJobTiming {
14741512
timing,err:=db.InsertProvisionerJobTimings(genCtx, database.InsertProvisionerJobTimingsParams{
14751513
JobID:takeFirst(seed.JobID,uuid.New()),

‎coderd/database/dbmetrics/querymetrics.go‎

Lines changed: 21 additions & 0 deletions
Some generated files are not rendered by default. Learn more aboutcustomizing how changed files appear on GitHub.

‎coderd/database/dbmock/dbmock.go‎

Lines changed: 45 additions & 0 deletions
Some generated files are not rendered by default. Learn more aboutcustomizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp