Method IncRunsCounter

app/controlplane/pkg/data/workflow.go:456–461

(ctx context.Context, workflowID uuid.UUID)

}

func (r *WorkflowRepo) IncRunsCounter(ctx context.Context, workflowID uuid.UUID) error {
	ctx, span := otelx.Start(ctx, workflowRepoTracer, "WorkflowRepo.IncRunsCounter")
	defer span.End()

	return r.data.DB.Workflow.Update().AddRunsCount(1).Where(workflow.ID(workflowID)).Exec(ctx)
}

func (r *WorkflowRepo) FindByID(ctx context.Context, id uuid.UUID) (*biz.Workflow, error) {
	ctx, span := otelx.Start(ctx, workflowRepoTracer, "WorkflowRepo.FindByID")