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

Commitf8869df

Browse files
chore(coderd/database): support status for a task
1 parentda467ba commitf8869df

File tree

14 files changed

+989
-119
lines changed

14 files changed

+989
-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
@@ -2842,6 +2842,10 @@ func (q *querier) GetTailnetTunnelPeerIDs(ctx context.Context, srcID uuid.UUID)
28422842
returnq.db.GetTailnetTunnelPeerIDs(ctx,srcID)
28432843
}
28442844

2845+
func (*querier)GetTaskByID(_ context.Context,_ uuid.UUID) (database.Task,error) {
2846+
panic("not implemented")
2847+
}
2848+
28452849
func (q*querier)GetTelemetryItem(ctx context.Context,keystring) (database.TelemetryItem,error) {
28462850
iferr:=q.authorizeContext(ctx,policy.ActionRead,rbac.ResourceSystem);err!=nil {
28472851
return database.TelemetryItem{},err
@@ -4067,6 +4071,14 @@ func (q *querier) InsertReplica(ctx context.Context, arg database.InsertReplicaP
40674071
returnq.db.InsertReplica(ctx,arg)
40684072
}
40694073

4074+
func (*querier)InsertTask(_ context.Context,_ database.InsertTaskParams) (database.TaskTable,error) {
4075+
panic("not implemented")
4076+
}
4077+
4078+
func (*querier)InsertTaskWorkspaceApp(_ context.Context,_ database.InsertTaskWorkspaceAppParams) (database.TaskWorkspaceApp,error) {
4079+
panic("not implemented")
4080+
}
4081+
40704082
func (q*querier)InsertTelemetryItemIfNotExists(ctx context.Context,arg database.InsertTelemetryItemIfNotExistsParams)error {
40714083
iferr:=q.authorizeContext(ctx,policy.ActionCreate,rbac.ResourceSystem);err!=nil {
40724084
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"
@@ -1471,6 +1472,43 @@ func ClaimPrebuild(
14711472
returnclaimedWorkspace
14721473
}
14731474

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