sqlcv1

type APIToken struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	ExpiresAt   pgtype.Timestamp `json:"expiresAt"`
	Revoked     bool             `json:"revoked"`
	Name        pgtype.Text      `json:"name"`
	TenantId    pgtype.UUID      `json:"tenantId"`
	NextAlertAt pgtype.Timestamp `json:"nextAlertAt"`
	Internal    bool             `json:"internal"`
}

type AcquireOrExtendLeasesParams struct {
	LeaseDuration    pgtype.Interval `json:"leaseDuration"`
	Tenantid         pgtype.UUID     `json:"tenantid"`
	Kind             LeaseKind       `json:"kind"`
	Resourceids      []string        `json:"resourceids"`
	Existingleaseids []int64         `json:"existingleaseids"`
}

type Action struct {
	Description pgtype.Text `json:"description"`
	TenantId    pgtype.UUID `json:"tenantId"`
	ActionId    string      `json:"actionId"`
	ID          pgtype.UUID `json:"id"`
}

type ActionToWorker struct {
	B pgtype.UUID `json:"B"`
	A pgtype.UUID `json:"A"`
}

type AddStepParentsParams struct {
	ID      pgtype.UUID `json:"id"`
	Parents []string    `json:"parents"`
	Jobid   pgtype.UUID `json:"jobid"`
}

type BulkCreateEventTriggersParams struct {
	RunID         int64              `json:"run_id"`
	RunInsertedAt pgtype.Timestamptz `json:"run_inserted_at"`
	EventID       int64              `json:"event_id"`
	EventSeenAt   pgtype.Timestamptz `json:"event_seen_at"`
	FilterID      pgtype.UUID        `json:"filter_id"`
}

type BulkCreateEventsParams struct {
	Tenantids              []pgtype.UUID        `json:"tenantids"`
	Externalids            []pgtype.UUID        `json:"externalids"`
	Seenats                []pgtype.Timestamptz `json:"seenats"`
	Keys                   []string             `json:"keys"`
	Payloads               [][]byte             `json:"payloads"`
	Additionalmetadatas    [][]byte             `json:"additionalmetadatas"`
	Scopes                 []pgtype.Text        `json:"scopes"`
	TriggeringWebhookNames []pgtype.Text        `json:"triggeringWebhookName"`
}

type BulkInsertDeclarativeFiltersParams struct {
	Tenantid    pgtype.UUID `json:"tenantid"`
	Workflowid  pgtype.UUID `json:"workflowid"`
	Scopes      []string    `json:"scopes"`
	Expressions []string    `json:"expressions"`
	Payloads    [][]byte    `json:"payloads"`
}

type BulkUpdateRateLimitsParams struct {
	Keys     []string    `json:"keys"`
	Units    []int32     `json:"units"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type CanCreateWebhookParams struct {
	Webhooklimit int32       `json:"webhooklimit"`
	Tenantid     pgtype.UUID `json:"tenantid"`
}

type CheckStrategyActiveParams struct {
	Workflowid        pgtype.UUID `json:"workflowid"`
	Tenantid          pgtype.UUID `json:"tenantid"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
	Strategyid        int64       `json:"strategyid"`
}

type ConcurrencyLimitStrategy string

type ControllerPartition struct {
	ID            string           `json:"id"`
	CreatedAt     pgtype.Timestamp `json:"createdAt"`
	UpdatedAt     pgtype.Timestamp `json:"updatedAt"`
	LastHeartbeat pgtype.Timestamp `json:"lastHeartbeat"`
	Name          pgtype.Text      `json:"name"`
}

type CountEventsParams struct {
	Tenantid           pgtype.UUID        `json:"tenantid"`
	Keys               []string           `json:"keys"`
	Since              pgtype.Timestamptz `json:"since"`
	Until              pgtype.Timestamptz `json:"until"`
	WorkflowIds        []pgtype.UUID      `json:"workflowIds"`
	EventIds           []pgtype.UUID      `json:"eventIds"`
	AdditionalMetadata []byte             `json:"additionalMetadata"`
	Statuses           []string           `json:"statuses"`
	Scopes             []string           `json:"scopes"`
}

type CountTasksParams struct {
	Tenantid                  pgtype.UUID        `json:"tenantid"`
	Since                     pgtype.Timestamptz `json:"since"`
	Statuses                  []string           `json:"statuses"`
	Until                     pgtype.Timestamptz `json:"until"`
	WorkflowIds               []pgtype.UUID      `json:"workflowIds"`
	WorkerId                  pgtype.UUID        `json:"workerId"`
	Keys                      []string           `json:"keys"`
	Values                    []string           `json:"values"`
	TriggeringEventExternalId pgtype.UUID        `json:"triggeringEventExternalId"`
}

type CountWorkflowRunsParams struct {
	Tenantid                  pgtype.UUID        `json:"tenantid"`
	Statuses                  []string           `json:"statuses"`
	WorkflowIds               []pgtype.UUID      `json:"workflowIds"`
	Since                     pgtype.Timestamptz `json:"since"`
	Until                     pgtype.Timestamptz `json:"until"`
	Keys                      []string           `json:"keys"`
	Values                    []string           `json:"values"`
	TriggeringEventExternalId pgtype.UUID        `json:"triggeringEventExternalId"`
}

type CreateDAGDataParams struct {
	DagID              int64              `json:"dag_id"`
	DagInsertedAt      pgtype.Timestamptz `json:"dag_inserted_at"`
	Input              []byte             `json:"input"`
	AdditionalMetadata []byte             `json:"additional_metadata"`
}

type CreateDAGsOLAPParams struct {
	TenantID             pgtype.UUID        `json:"tenant_id"`
	ID                   int64              `json:"id"`
	InsertedAt           pgtype.Timestamptz `json:"inserted_at"`
	ExternalID           pgtype.UUID        `json:"external_id"`
	DisplayName          string             `json:"display_name"`
	WorkflowID           pgtype.UUID        `json:"workflow_id"`
	WorkflowVersionID    pgtype.UUID        `json:"workflow_version_id"`
	Input                []byte             `json:"input"`
	AdditionalMetadata   []byte             `json:"additional_metadata"`
	ParentTaskExternalID pgtype.UUID        `json:"parent_task_external_id"`
	TotalTasks           int32              `json:"total_tasks"`
}

type CreateDAGsParams struct {
	Tenantids             []pgtype.UUID `json:"tenantids"`
	Externalids           []pgtype.UUID `json:"externalids"`
	Displaynames          []string      `json:"displaynames"`
	Workflowids           []pgtype.UUID `json:"workflowids"`
	Workflowversionids    []pgtype.UUID `json:"workflowversionids"`
	Parenttaskexternalids []pgtype.UUID `json:"parenttaskexternalids"`
}

type CreateDurableSleepParams struct {
	TenantID       pgtype.UUID `json:"tenant_id"`
	SleepDurations []string    `json:"sleep_durations"`
}

type CreateFilterParams struct {
	Tenantid   pgtype.UUID `json:"tenantid"`
	Workflowid pgtype.UUID `json:"workflowid"`
	Scope      string      `json:"scope"`
	Expression string      `json:"expression"`
	Payload    []byte      `json:"payload"`
}

type CreateIncomingWebhookValidationFailureLogsParams struct {
	Tenantid             pgtype.UUID `json:"tenantid"`
	Incomingwebhooknames []string    `json:"incomingwebhooknames"`
	Errors               []string    `json:"errors"`
}

type CreateJobParams struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	Deletedat         pgtype.Timestamp `json:"deletedat"`
	Tenantid          pgtype.UUID      `json:"tenantid"`
	Workflowversionid pgtype.UUID      `json:"workflowversionid"`
	Name              string           `json:"name"`
	Description       string           `json:"description"`
	Kind              NullJobKind      `json:"kind"`
}

type CreateMatchConditionsParams struct {
	V1MatchID         int64                  `json:"v1_match_id"`
	TenantID          pgtype.UUID            `json:"tenant_id"`
	EventType         V1EventType            `json:"event_type"`
	EventKey          string                 `json:"event_key"`
	EventResourceHint pgtype.Text            `json:"event_resource_hint"`
	ReadableDataKey   string                 `json:"readable_data_key"`
	OrGroupID         pgtype.UUID            `json:"or_group_id"`
	Expression        pgtype.Text            `json:"expression"`
	Action            V1MatchConditionAction `json:"action"`
	IsSatisfied       bool                   `json:"is_satisfied"`
	Data              []byte                 `json:"data"`
}

type CreateMatchesForDAGTriggersParams struct {
	Tenantids                     []pgtype.UUID        `json:"tenantids"`
	Kinds                         []string             `json:"kinds"`
	ExistingDatas                 [][]byte             `json:"existingDatas"`
	Triggerdagids                 []int64              `json:"triggerdagids"`
	Triggerdaginsertedats         []pgtype.Timestamptz `json:"triggerdaginsertedats"`
	Triggerstepids                []pgtype.UUID        `json:"triggerstepids"`
	Triggerstepindex              []int64              `json:"triggerstepindex"`
	Triggerexternalids            []pgtype.UUID        `json:"triggerexternalids"`
	Triggerworkflowrunids         []pgtype.UUID        `json:"triggerworkflowrunids"`
	Triggerexistingtaskids        []pgtype.Int8        `json:"triggerexistingtaskids"`
	Triggerexistingtaskinsertedat []pgtype.Timestamptz `json:"triggerexistingtaskinsertedat"`
	TriggerParentTaskExternalIds  []pgtype.UUID        `json:"triggerparentTaskExternalIds"`
	TriggerParentTaskIds          []pgtype.Int8        `json:"triggerparentTaskIds"`
	TriggerParentTaskInsertedAt   []pgtype.Timestamptz `json:"triggerparentTaskInsertedAt"`
	TriggerChildIndex             []pgtype.Int8        `json:"triggerchildIndex"`
	TriggerChildKey               []pgtype.Text        `json:"triggerchildKey"`
	TriggerPriorities             []pgtype.Int4        `json:"triggerPriorities"`
}

type CreateMatchesForSignalTriggersParams struct {
	Tenantids             []pgtype.UUID        `json:"tenantids"`
	Kinds                 []string             `json:"kinds"`
	Signaltaskids         []int64              `json:"signaltaskids"`
	Signaltaskinsertedats []pgtype.Timestamptz `json:"signaltaskinsertedats"`
	Signalexternalids     []pgtype.UUID        `json:"signalexternalids"`
	Signalkeys            []string             `json:"signalkeys"`
}

type CreateOLAPPartitionsParams struct {
	Partitions int32       `json:"partitions"`
	Date       pgtype.Date `json:"date"`
}

type CreateStepConcurrencyParams struct {
	Workflowid        pgtype.UUID           `json:"workflowid"`
	Workflowversionid pgtype.UUID           `json:"workflowversionid"`
	Stepid            pgtype.UUID           `json:"stepid"`
	Strategy          V1ConcurrencyStrategy `json:"strategy"`
	Expression        string                `json:"expression"`
	Tenantid          pgtype.UUID           `json:"tenantid"`
	Maxconcurrency    int32                 `json:"maxconcurrency"`
}

type CreateStepExpressionsParams struct {
	Keys        []string    `json:"keys"`
	Stepid      pgtype.UUID `json:"stepid"`
	Expressions []string    `json:"expressions"`
	Kinds       []string    `json:"kinds"`
}

type CreateStepMatchConditionParams struct {
	Tenantid         pgtype.UUID              `json:"tenantid"`
	Stepid           pgtype.UUID              `json:"stepid"`
	Readabledatakey  string                   `json:"readabledatakey"`
	Action           V1MatchConditionAction   `json:"action"`
	Orgroupid        pgtype.UUID              `json:"orgroupid"`
	Expression       pgtype.Text              `json:"expression"`
	Kind             V1StepMatchConditionKind `json:"kind"`
	SleepDuration    pgtype.Text              `json:"sleepDuration"`
	EventKey         pgtype.Text              `json:"eventKey"`
	ParentReadableId pgtype.Text              `json:"parentReadableId"`
}

type CreateStepParams struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	Deletedat          pgtype.Timestamp `json:"deletedat"`
	Readableid         string           `json:"readableid"`
	Tenantid           pgtype.UUID      `json:"tenantid"`
	Jobid              pgtype.UUID      `json:"jobid"`
	Actionid           string           `json:"actionid"`
	Timeout            pgtype.Text      `json:"timeout"`
	CustomUserData     []byte           `json:"customUserData"`
	Retries            pgtype.Int4      `json:"retries"`
	ScheduleTimeout    pgtype.Text      `json:"scheduleTimeout"`
	RetryBackoffFactor pgtype.Float8    `json:"retryBackoffFactor"`
	RetryMaxBackoff    pgtype.Int4      `json:"retryMaxBackoff"`
}

type CreateStepRateLimitParams struct {
	Units        int32             `json:"units"`
	Stepid       pgtype.UUID       `json:"stepid"`
	Ratelimitkey string            `json:"ratelimitkey"`
	Tenantid     pgtype.UUID       `json:"tenantid"`
	Kind         StepRateLimitKind `json:"kind"`
}

type CreateTaskEventsOLAPParams struct {
	TenantID               pgtype.UUID          `json:"tenant_id"`
	TaskID                 int64                `json:"task_id"`
	TaskInsertedAt         pgtype.Timestamptz   `json:"task_inserted_at"`
	EventType              V1EventTypeOlap      `json:"event_type"`
	WorkflowID             pgtype.UUID          `json:"workflow_id"`
	EventTimestamp         pgtype.Timestamptz   `json:"event_timestamp"`
	ReadableStatus         V1ReadableStatusOlap `json:"readable_status"`
	RetryCount             int32                `json:"retry_count"`
	ErrorMessage           pgtype.Text          `json:"error_message"`
	Output                 []byte               `json:"output"`
	WorkerID               pgtype.UUID          `json:"worker_id"`
	AdditionalEventData    pgtype.Text          `json:"additional__event_data"`
	AdditionalEventMessage pgtype.Text          `json:"additional__event_message"`
}

type CreateTaskEventsOLAPTmpParams struct {
	TenantID       pgtype.UUID          `json:"tenant_id"`
	TaskID         int64                `json:"task_id"`
	TaskInsertedAt pgtype.Timestamptz   `json:"task_inserted_at"`
	EventType      V1EventTypeOlap      `json:"event_type"`
	ReadableStatus V1ReadableStatusOlap `json:"readable_status"`
	RetryCount     int32                `json:"retry_count"`
	WorkerID       pgtype.UUID          `json:"worker_id"`
}

type CreateTaskEventsParams struct {
	Tenantid        pgtype.UUID          `json:"tenantid"`
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Retrycounts     []int32              `json:"retrycounts"`
	Eventtypes      []string             `json:"eventtypes"`
	Eventkeys       []pgtype.Text        `json:"eventkeys"`
	Datas           [][]byte             `json:"datas"`
}

type CreateTaskExpressionEvalsParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Keys            []string             `json:"keys"`
	Valuesstr       []pgtype.Text        `json:"valuesstr"`
	Valuesint       []pgtype.Int4        `json:"valuesint"`
	Kinds           []string             `json:"kinds"`
}

type CreateTasksOLAPParams struct {
	TenantID             pgtype.UUID          `json:"tenant_id"`
	ID                   int64                `json:"id"`
	InsertedAt           pgtype.Timestamptz   `json:"inserted_at"`
	Queue                string               `json:"queue"`
	ActionID             string               `json:"action_id"`
	StepID               pgtype.UUID          `json:"step_id"`
	WorkflowID           pgtype.UUID          `json:"workflow_id"`
	WorkflowVersionID    pgtype.UUID          `json:"workflow_version_id"`
	WorkflowRunID        pgtype.UUID          `json:"workflow_run_id"`
	ScheduleTimeout      string               `json:"schedule_timeout"`
	StepTimeout          pgtype.Text          `json:"step_timeout"`
	Priority             pgtype.Int4          `json:"priority"`
	Sticky               V1StickyStrategyOlap `json:"sticky"`
	DesiredWorkerID      pgtype.UUID          `json:"desired_worker_id"`
	ExternalID           pgtype.UUID          `json:"external_id"`
	DisplayName          string               `json:"display_name"`
	Input                []byte               `json:"input"`
	AdditionalMetadata   []byte               `json:"additional_metadata"`
	DagID                pgtype.Int8          `json:"dag_id"`
	DagInsertedAt        pgtype.Timestamptz   `json:"dag_inserted_at"`
	ParentTaskExternalID pgtype.UUID          `json:"parent_task_external_id"`
}

type CreateTasksParams struct {
	Tenantids           []pgtype.UUID        `json:"tenantids"`
	Queues              []string             `json:"queues"`
	Actionids           []string             `json:"actionids"`
	Stepids             []pgtype.UUID        `json:"stepids"`
	Stepreadableids     []string             `json:"stepreadableids"`
	Workflowids         []pgtype.UUID        `json:"workflowids"`
	Scheduletimeouts    []string             `json:"scheduletimeouts"`
	Steptimeouts        []string             `json:"steptimeouts"`
	Priorities          []int32              `json:"priorities"`
	Stickies            []string             `json:"stickies"`
	Desiredworkerids    []pgtype.UUID        `json:"desiredworkerids"`
	Externalids         []pgtype.UUID        `json:"externalids"`
	Displaynames        []string             `json:"displaynames"`
	Inputs              [][]byte             `json:"inputs"`
	Retrycounts         []int32              `json:"retrycounts"`
	Additionalmetadatas [][]byte             `json:"additionalmetadatas"`
	InitialStates       []string             `json:"initialstates"`
	InitialStateReasons []pgtype.Text        `json:"initialStateReasons"`
	Dagids              []pgtype.Int8        `json:"dagids"`
	Daginsertedats      []pgtype.Timestamptz `json:"daginsertedats"`
	// FIXME: pgx doesn't like multi-dimensional arrays with different lengths, these types
	// probably need to change. Current hack is to group tasks by their step id where these
	// multi-dimensional arrays are the same length.
	Concurrencyparentstrategyids [][]pgtype.Int8      `json:"concurrencyparentstrategyids"`
	ConcurrencyStrategyIds       [][]int64            `json:"concurrencyStrategyIds"`
	ConcurrencyKeys              [][]string           `json:"concurrencyKeys"`
	ParentTaskExternalIds        []pgtype.UUID        `json:"parentTaskExternalIds"`
	ParentTaskIds                []pgtype.Int8        `json:"parentTaskIds"`
	ParentTaskInsertedAts        []pgtype.Timestamptz `json:"parentTaskInsertedAts"`
	ChildIndex                   []pgtype.Int8        `json:"childIndex"`
	ChildKey                     []pgtype.Text        `json:"childKey"`
	StepIndex                    []int64              `json:"stepIndex"`
	RetryBackoffFactor           []pgtype.Float8      `json:"retryBackoffFactor"`
	RetryMaxBackoff              []pgtype.Int4        `json:"retryMaxBackoff"`
	WorkflowVersionIds           []pgtype.UUID        `json:"workflowVersionIds"`
	WorkflowRunIds               []pgtype.UUID        `json:"workflowRunIds"`
}

type CreateWebhookParams struct {
	Tenantid                     pgtype.UUID                        `json:"tenantid"`
	Name                         string                             `json:"name"`
	Sourcename                   V1IncomingWebhookSourceName        `json:"sourcename"`
	Eventkeyexpression           string                             `json:"eventkeyexpression"`
	Authmethod                   V1IncomingWebhookAuthType          `json:"authmethod"`
	AuthBasicUsername            pgtype.Text                        `json:"authBasicUsername"`
	Authbasicpassword            []byte                             `json:"authbasicpassword"`
	AuthApiKeyHeaderName         pgtype.Text                        `json:"authApiKeyHeaderName"`
	Authapikeykey                []byte                             `json:"authapikeykey"`
	AuthHmacAlgorithm            NullV1IncomingWebhookHmacAlgorithm `json:"authHmacAlgorithm"`
	AuthHmacEncoding             NullV1IncomingWebhookHmacEncoding  `json:"authHmacEncoding"`
	AuthHmacSignatureHeaderName  pgtype.Text                        `json:"authHmacSignatureHeaderName"`
	Authhmacwebhooksigningsecret []byte                             `json:"authhmacwebhooksigningsecret"`
}

type CreateWorkflowConcurrencyParams struct {
	CreatedAt                  pgtype.Timestamp             `json:"createdAt"`
	UpdatedAt                  pgtype.Timestamp             `json:"updatedAt"`
	Workflowversionid          pgtype.UUID                  `json:"workflowversionid"`
	GetConcurrencyGroupId      pgtype.UUID                  `json:"getConcurrencyGroupId"`
	MaxRuns                    pgtype.Int4                  `json:"maxRuns"`
	LimitStrategy              NullConcurrencyLimitStrategy `json:"limitStrategy"`
	ConcurrencyGroupExpression pgtype.Text                  `json:"concurrencyGroupExpression"`
}

type CreateWorkflowConcurrencyV1Params struct {
	Workflowid        pgtype.UUID           `json:"workflowid"`
	Workflowversionid pgtype.UUID           `json:"workflowversionid"`
	Limitstrategy     V1ConcurrencyStrategy `json:"limitstrategy"`
	Expression        string                `json:"expression"`
	Tenantid          pgtype.UUID           `json:"tenantid"`
	MaxRuns           pgtype.Int4           `json:"maxRuns"`
}

type CreateWorkflowConcurrencyV1Row struct {
	ID               int64   `json:"id"`
	ChildStrategyIds []int64 `json:"child_strategy_ids"`
}

type CreateWorkflowParams struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	Deletedat   pgtype.Timestamp `json:"deletedat"`
	Tenantid    pgtype.UUID      `json:"tenantid"`
	Name        string           `json:"name"`
	Description string           `json:"description"`
}

type CreateWorkflowTriggerCronRefParams struct {
	Workflowtriggersid pgtype.UUID                       `json:"workflowtriggersid"`
	Crontrigger        string                            `json:"crontrigger"`
	Name               pgtype.Text                       `json:"name"`
	Input              []byte                            `json:"input"`
	AdditionalMetadata []byte                            `json:"additionalMetadata"`
	Method             NullWorkflowTriggerCronRefMethods `json:"method"`
	Priority           pgtype.Int4                       `json:"priority"`
}

type CreateWorkflowTriggerEventRefParams struct {
	Workflowtriggersid pgtype.UUID `json:"workflowtriggersid"`
	Eventtrigger       string      `json:"eventtrigger"`
}

type CreateWorkflowTriggersParams struct {
	ID                pgtype.UUID `json:"id"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
	Tenantid          pgtype.UUID `json:"tenantid"`
}

type CreateWorkflowVersionParams struct {
	ID                        pgtype.UUID        `json:"id"`
	CreatedAt                 pgtype.Timestamp   `json:"createdAt"`
	UpdatedAt                 pgtype.Timestamp   `json:"updatedAt"`
	Deletedat                 pgtype.Timestamp   `json:"deletedat"`
	Checksum                  string             `json:"checksum"`
	Version                   pgtype.Text        `json:"version"`
	Workflowid                pgtype.UUID        `json:"workflowid"`
	Sticky                    NullStickyStrategy `json:"sticky"`
	Kind                      NullWorkflowKind   `json:"kind"`
	DefaultPriority           pgtype.Int4        `json:"defaultPriority"`
	CreateWorkflowVersionOpts []byte             `json:"createWorkflowVersionOpts"`
}

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

type DeleteExistingDeclarativeFiltersForOverwriteParams struct {
	Tenantid   pgtype.UUID `json:"tenantid"`
	Workflowid pgtype.UUID `json:"workflowid"`
}

type DeleteFilterParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	ID       pgtype.UUID `json:"id"`
}

type DeleteMatchingSignalEventsParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Eventkeys       []string             `json:"eventkeys"`
	Tenantid        pgtype.UUID          `json:"tenantid"`
	Eventtype       V1TaskEventType      `json:"eventtype"`
}

type DeleteTasksFromQueueParams struct {
	Taskids     []int64 `json:"taskids"`
	Retrycounts []int32 `json:"retrycounts"`
}

type DeleteWebhookParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Name     string      `json:"name"`
}

type Dispatcher struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	IsActive        bool             `json:"isActive"`
}

type Event struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	Key                string           `json:"key"`
	TenantId           pgtype.UUID      `json:"tenantId"`
	ReplayedFromId     pgtype.UUID      `json:"replayedFromId"`
	Data               []byte           `json:"data"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	InsertOrder        pgtype.Int4      `json:"insertOrder"`
}

type EventKey struct {
	Key      string      `json:"key"`
	TenantId pgtype.UUID `json:"tenantId"`
	ID       int64       `json:"id"`
}

type FailTaskAppFailureParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Taskretrycounts []int32              `json:"taskretrycounts"`
	Isnonretryables []bool               `json:"isnonretryables"`
	Tenantid        pgtype.UUID          `json:"tenantid"`
}

type FailTaskAppFailureRow struct {
	ID                 int64              `json:"id"`
	InsertedAt         pgtype.Timestamptz `json:"inserted_at"`
	RetryCount         int32              `json:"retry_count"`
	AppRetryCount      int32              `json:"app_retry_count"`
	RetryBackoffFactor pgtype.Float8      `json:"retry_backoff_factor"`
	RetryMaxBackoff    pgtype.Int4        `json:"retry_max_backoff"`
}

type FailTaskInternalFailureParams struct {
	Maxinternalretries int32                `json:"maxinternalretries"`
	Taskids            []int64              `json:"taskids"`
	Taskinsertedats    []pgtype.Timestamptz `json:"taskinsertedats"`
	Taskretrycounts    []int32              `json:"taskretrycounts"`
	Tenantid           pgtype.UUID          `json:"tenantid"`
}

type FailTaskInternalFailureRow struct {
	ID         int64              `json:"id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
	RetryCount int32              `json:"retry_count"`
}

type FetchWorkflowRunIdsParams struct {
	Tenantid                  pgtype.UUID        `json:"tenantid"`
	Statuses                  []string           `json:"statuses"`
	WorkflowIds               []pgtype.UUID      `json:"workflowIds"`
	Since                     pgtype.Timestamptz `json:"since"`
	Until                     pgtype.Timestamptz `json:"until"`
	Keys                      []string           `json:"keys"`
	Values                    []string           `json:"values"`
	Listworkflowrunsoffset    int32              `json:"listworkflowrunsoffset"`
	Listworkflowrunslimit     int32              `json:"listworkflowrunslimit"`
	ParentTaskExternalId      pgtype.UUID        `json:"parentTaskExternalId"`
	TriggeringEventExternalId pgtype.UUID        `json:"triggeringEventExternalId"`
}

type FetchWorkflowRunIdsRow struct {
	ID         int64              `json:"id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
	Kind       V1RunKind          `json:"kind"`
	ExternalID pgtype.UUID        `json:"external_id"`
}

type FindMinInsertedAtForDAGStatusUpdatesParams struct {
	Partitionnumber int32         `json:"partitionnumber"`
	Eventlimit      int32         `json:"eventlimit"`
	Tenantids       []pgtype.UUID `json:"tenantids"`
}

type FindMinInsertedAtForTaskStatusUpdatesParams struct {
	Partitionnumber int32         `json:"partitionnumber"`
	Eventlimit      int32         `json:"eventlimit"`
	Tenantids       []pgtype.UUID `json:"tenantids"`
}

type FlattenExternalIdsParams struct {
	Externalids []pgtype.UUID `json:"externalids"`
	Tenantid    pgtype.UUID   `json:"tenantid"`
}

type FlattenExternalIdsRow struct {
	ID                    int64              `json:"id"`
	InsertedAt            pgtype.Timestamptz `json:"inserted_at"`
	RetryCount            int32              `json:"retry_count"`
	ExternalID            pgtype.UUID        `json:"external_id"`
	WorkflowRunID         pgtype.UUID        `json:"workflow_run_id"`
	AdditionalMetadata    []byte             `json:"additional_metadata"`
	DagID                 pgtype.Int8        `json:"dag_id"`
	DagInsertedAt         pgtype.Timestamptz `json:"dag_inserted_at"`
	ParentTaskID          pgtype.Int8        `json:"parent_task_id"`
	ChildIndex            pgtype.Int8        `json:"child_index"`
	ChildKey              pgtype.Text        `json:"child_key"`
	WorkflowRunExternalID pgtype.UUID        `json:"workflow_run_external_id"`
}

type FlattenTasksByExternalIdsParams struct {
	Externalids []pgtype.UUID `json:"externalids"`
	Tenantid    pgtype.UUID   `json:"tenantid"`
}

type FlattenTasksByExternalIdsRow struct {
	TenantID   pgtype.UUID        `json:"tenant_id"`
	ID         int64              `json:"id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
	ExternalID pgtype.UUID        `json:"external_id"`
	RetryCount int32              `json:"retry_count"`
}

type GetDAGDataParams struct {
	Dagids         []int64              `json:"dagids"`
	Daginsertedats []pgtype.Timestamptz `json:"daginsertedats"`
}

type GetDAGDataRow struct {
	DagID              int64              `json:"dag_id"`
	DagInsertedAt      pgtype.Timestamptz `json:"dag_inserted_at"`
	Input              []byte             `json:"input"`
	AdditionalMetadata []byte             `json:"additional_metadata"`
	DagID_2            interface{}        `json:"dag_id_2"`
	DagInsertedAt_2    interface{}        `json:"dag_inserted_at_2"`
}

type GetDagDurationsParams struct {
	Externalids   []pgtype.UUID      `json:"externalids"`
	Tenantid      pgtype.UUID        `json:"tenantid"`
	Mininsertedat pgtype.Timestamptz `json:"mininsertedat"`
}

type GetDagDurationsRow struct {
	ExternalID pgtype.UUID        `json:"external_id"`
	StartedAt  pgtype.Timestamptz `json:"started_at"`
	FinishedAt pgtype.Timestamptz `json:"finished_at"`
}

type GetDesiredLabelsRow struct {
	Key        string                `json:"key"`
	StrValue   pgtype.Text           `json:"strValue"`
	IntValue   pgtype.Int4           `json:"intValue"`
	Required   bool                  `json:"required"`
	Weight     int32                 `json:"weight"`
	Comparator WorkerLabelComparator `json:"comparator"`
	StepId     pgtype.UUID           `json:"stepId"`
}

type GetFilterParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	ID       pgtype.UUID `json:"id"`
}

type GetGroupKeyRun struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	DeletedAt         pgtype.Timestamp `json:"deletedAt"`
	TenantId          pgtype.UUID      `json:"tenantId"`
	WorkerId          pgtype.UUID      `json:"workerId"`
	TickerId          pgtype.UUID      `json:"tickerId"`
	Status            StepRunStatus    `json:"status"`
	Input             []byte           `json:"input"`
	Output            pgtype.Text      `json:"output"`
	RequeueAfter      pgtype.Timestamp `json:"requeueAfter"`
	Error             pgtype.Text      `json:"error"`
	StartedAt         pgtype.Timestamp `json:"startedAt"`
	FinishedAt        pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt         pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt       pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason   pgtype.Text      `json:"cancelledReason"`
	CancelledError    pgtype.Text      `json:"cancelledError"`
	WorkflowRunId     pgtype.UUID      `json:"workflowRunId"`
	ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
}

type GetLatestWorkflowVersionForWorkflowsParams struct {
	Tenantid    pgtype.UUID   `json:"tenantid"`
	Workflowids []pgtype.UUID `json:"workflowids"`
}

type GetLeasesToAcquireParams struct {
	Tenantid    pgtype.UUID `json:"tenantid"`
	Kind        LeaseKind   `json:"kind"`
	Resourceids []string    `json:"resourceids"`
}

type GetMinUnprocessedQueueItemIdParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Queue    string      `json:"queue"`
}

type GetQueuedCountsRow struct {
	Queue string `json:"queue"`
	Count int64  `json:"count"`
}

type GetRunsListRecursiveParams struct {
	Tenantid        pgtype.UUID        `json:"tenantid"`
	Taskexternalids []pgtype.UUID      `json:"taskexternalids"`
	Depth           int32              `json:"depth"`
	Createdafter    pgtype.Timestamptz `json:"createdafter"`
}

type GetRunsListRecursiveRow struct {
	TenantID             pgtype.UUID        `json:"tenant_id"`
	ID                   int64              `json:"id"`
	InsertedAt           pgtype.Timestamptz `json:"inserted_at"`
	ExternalID           pgtype.UUID        `json:"external_id"`
	ParentTaskExternalID pgtype.UUID        `json:"parent_task_external_id"`
	Depth                int32              `json:"depth"`
}

type GetSatisfiedMatchConditionsParams struct {
	Matchids     []int64  `json:"matchids"`
	Conditionids []int64  `json:"conditionids"`
	Datas        [][]byte `json:"datas"`
}

type GetTaskDurationsByTaskIdsParams struct {
	Taskids          []int64                `json:"taskids"`
	Taskinsertedats  []pgtype.Timestamptz   `json:"taskinsertedats"`
	Readablestatuses []V1ReadableStatusOlap `json:"readablestatuses"`
	Tenantid         pgtype.UUID            `json:"tenantid"`
}

type GetTaskDurationsByTaskIdsRow struct {
	StartedAt  pgtype.Timestamptz `json:"started_at"`
	FinishedAt pgtype.Timestamptz `json:"finished_at"`
}

type GetTaskPointMetricsParams struct {
	Interval      pgtype.Interval    `json:"interval"`
	Tenantid      pgtype.UUID        `json:"tenantid"`
	Createdafter  pgtype.Timestamptz `json:"createdafter"`
	Createdbefore pgtype.Timestamptz `json:"createdbefore"`
}

type GetTaskPointMetricsRow struct {
	Bucket2        pgtype.Timestamptz `json:"bucket_2"`
	CompletedCount int64              `json:"completed_count"`
	FailedCount    int64              `json:"failed_count"`
}

type GetTenantStatusMetricsParams struct {
	Tenantid                  pgtype.UUID        `json:"tenantid"`
	Createdafter              pgtype.Timestamptz `json:"createdafter"`
	CreatedBefore             pgtype.Timestamptz `json:"createdBefore"`
	WorkflowIds               []pgtype.UUID      `json:"workflowIds"`
	ParentTaskExternalId      pgtype.UUID        `json:"parentTaskExternalId"`
	TriggeringEventExternalId pgtype.UUID        `json:"triggeringEventExternalId"`
}

type GetTenantStatusMetricsRow struct {
	TenantID       pgtype.UUID `json:"tenant_id"`
	TotalQueued    int64       `json:"total_queued"`
	TotalRunning   int64       `json:"total_running"`
	TotalCompleted int64       `json:"total_completed"`
	TotalCancelled int64       `json:"total_cancelled"`
	TotalFailed    int64       `json:"total_failed"`
}

type GetWebhookParams struct {
	Name     string      `json:"name"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type GetWorkerByIdRow struct {
	Worker         Worker      `json:"worker"`
	WebhookUrl     pgtype.Text `json:"webhookUrl"`
	RemainingSlots int32       `json:"remainingSlots"`
}

type GetWorkflowByNameParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Name     string      `json:"name"`
}

type GetWorkflowConcurrencyQueueCountsRow struct {
	WorkflowName string `json:"workflowName"`
	Key          string `json:"key"`
	Count        int64  `json:"count"`
}

type GetWorkflowRunIdFromDagIdInsertedAtParams struct {
	Dagid         int64              `json:"dagid"`
	Daginsertedat pgtype.Timestamptz `json:"daginsertedat"`
}

type GetWorkflowVersionForEngineParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type GetWorkflowVersionForEngineRow struct {
	WorkflowVersion            WorkflowVersion              `json:"workflow_version"`
	WorkflowName               string                       `json:"workflowName"`
	ConcurrencyLimitStrategy   NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
	ConcurrencyMaxRuns         pgtype.Int4                  `json:"concurrencyMaxRuns"`
	ConcurrencyGroupId         pgtype.UUID                  `json:"concurrencyGroupId"`
	ConcurrencyGroupExpression pgtype.Text                  `json:"concurrencyGroupExpression"`
}

type InsertLogLineParams struct {
	TenantID       pgtype.UUID        `json:"tenant_id"`
	TaskID         int64              `json:"task_id"`
	TaskInsertedAt pgtype.Timestamptz `json:"task_inserted_at"`
	Message        string             `json:"message"`
	Metadata       []byte             `json:"metadata"`
	RetryCount     int32              `json:"retry_count"`
	Level          V1LogLineLevel     `json:"level"`
}

type InternalQueue string

type InternalQueueItem struct {
	ID        int64         `json:"id"`
	Queue     InternalQueue `json:"queue"`
	IsQueued  bool          `json:"isQueued"`
	Data      []byte        `json:"data"`
	TenantId  pgtype.UUID   `json:"tenantId"`
	Priority  int32         `json:"priority"`
	UniqueKey pgtype.Text   `json:"uniqueKey"`
}

type InviteLinkStatus string

type IsTenantAlertActiveRow struct {
	IsActive      bool             `json:"isActive"`
	LastAlertedAt pgtype.Timestamp `json:"lastAlertedAt"`
}

type Job struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	DeletedAt         pgtype.Timestamp `json:"deletedAt"`
	TenantId          pgtype.UUID      `json:"tenantId"`
	WorkflowVersionId pgtype.UUID      `json:"workflowVersionId"`
	Name              string           `json:"name"`
	Description       pgtype.Text      `json:"description"`
	Timeout           pgtype.Text      `json:"timeout"`
	Kind              JobKind          `json:"kind"`
}

type JobKind string

type JobRun struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	TenantId        pgtype.UUID      `json:"tenantId"`
	JobId           pgtype.UUID      `json:"jobId"`
	TickerId        pgtype.UUID      `json:"tickerId"`
	Status          JobRunStatus     `json:"status"`
	Result          []byte           `json:"result"`
	StartedAt       pgtype.Timestamp `json:"startedAt"`
	FinishedAt      pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt       pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt     pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason pgtype.Text      `json:"cancelledReason"`
	CancelledError  pgtype.Text      `json:"cancelledError"`
	WorkflowRunId   pgtype.UUID      `json:"workflowRunId"`
}

type JobRunLookupData struct {
	ID        pgtype.UUID      `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	DeletedAt pgtype.Timestamp `json:"deletedAt"`
	JobRunId  pgtype.UUID      `json:"jobRunId"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	Data      []byte           `json:"data"`
}

type JobRunStatus string

type Lease struct {
	ID         int64            `json:"id"`
	ExpiresAt  pgtype.Timestamp `json:"expiresAt"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	ResourceId string           `json:"resourceId"`
	Kind       LeaseKind        `json:"kind"`
}

type LeaseKind string

type LimitResource string

type LinkOnFailureJobParams struct {
	Jobid             pgtype.UUID `json:"jobid"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
}

type ListActionsForWorkersParams struct {
	Tenantid  pgtype.UUID   `json:"tenantid"`
	Workerids []pgtype.UUID `json:"workerids"`
}

type ListActionsForWorkersRow struct {
	WorkerId pgtype.UUID `json:"workerId"`
	ActionId pgtype.Text `json:"actionId"`
}

type ListActiveWorkersRow struct {
	ID      pgtype.UUID `json:"id"`
	MaxRuns int32       `json:"maxRuns"`
}

type ListAllTasksInDagsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Dagids   []int64     `json:"dagids"`
}

type ListAllTasksInDagsRow struct {
	ID             int64              `json:"id"`
	InsertedAt     pgtype.Timestamptz `json:"inserted_at"`
	RetryCount     int32              `json:"retry_count"`
	DagID          pgtype.Int8        `json:"dag_id"`
	DagInsertedAt  pgtype.Timestamptz `json:"dag_inserted_at"`
	StepReadableID string             `json:"step_readable_id"`
	StepID         pgtype.UUID        `json:"step_id"`
	WorkflowID     pgtype.UUID        `json:"workflow_id"`
	ExternalID     pgtype.UUID        `json:"external_id"`
}

type ListAvailableSlotsForWorkersParams struct {
	Tenantid  pgtype.UUID   `json:"tenantid"`
	Workerids []pgtype.UUID `json:"workerids"`
}

type ListAvailableSlotsForWorkersRow struct {
	ID             pgtype.UUID `json:"id"`
	AvailableSlots int32       `json:"availableSlots"`
}

type ListConcurrencyStrategiesByStepIdParams struct {
	Tenantid pgtype.UUID   `json:"tenantid"`
	Stepids  []pgtype.UUID `json:"stepids"`
}

type ListEventsParams struct {
	Tenantid           pgtype.UUID        `json:"tenantid"`
	Keys               []string           `json:"keys"`
	Since              pgtype.Timestamptz `json:"since"`
	Until              pgtype.Timestamptz `json:"until"`
	WorkflowIds        []pgtype.UUID      `json:"workflowIds"`
	EventIds           []pgtype.UUID      `json:"eventIds"`
	AdditionalMetadata []byte             `json:"additionalMetadata"`
	Statuses           []string           `json:"statuses"`
	Scopes             []string           `json:"scopes"`
	Offset             pgtype.Int8        `json:"offset"`
	Limit              pgtype.Int8        `json:"limit"`
}

type ListFilterCountsForWorkflowsParams struct {
	Tenantid    pgtype.UUID   `json:"tenantid"`
	Workflowids []pgtype.UUID `json:"workflowids"`
}

type ListFilterCountsForWorkflowsRow struct {
	WorkflowID pgtype.UUID `json:"workflow_id"`
	Count      int64       `json:"count"`
}

type ListFiltersForEventTriggersParams struct {
	Tenantid     pgtype.UUID   `json:"tenantid"`
	FilterOffset pgtype.Int8   `json:"filterOffset"`
	FilterLimit  pgtype.Int8   `json:"filterLimit"`
	Workflowids  []pgtype.UUID `json:"workflowids"`
	Scopes       []string      `json:"scopes"`
}

type ListFiltersParams struct {
	Tenantid     pgtype.UUID   `json:"tenantid"`
	WorkflowIds  []pgtype.UUID `json:"workflowIds"`
	Scopes       []string      `json:"scopes"`
	FilterOffset pgtype.Int8   `json:"filterOffset"`
	FilterLimit  pgtype.Int8   `json:"filterLimit"`
}

type ListLogLinesParams struct {
	Tenantid       pgtype.UUID        `json:"tenantid"`
	Taskid         int64              `json:"taskid"`
	Taskinsertedat pgtype.Timestamptz `json:"taskinsertedat"`
	Search         pgtype.Text        `json:"search"`
	Offset         interface{}        `json:"offset"`
	Limit          interface{}        `json:"limit"`
}

type ListManyWorkerLabelsRow struct {
	ID        int64            `json:"id"`
	Key       string           `json:"key"`
	IntValue  pgtype.Int4      `json:"intValue"`
	StrValue  pgtype.Text      `json:"strValue"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	WorkerId  pgtype.UUID      `json:"workerId"`
}

type ListMatchConditionsForEventRow struct {
	V1MatchID         int64              `json:"v1_match_id"`
	ID                int64              `json:"id"`
	RegisteredAt      pgtype.Timestamptz `json:"registered_at"`
	EventType         V1EventType        `json:"event_type"`
	EventKey          string             `json:"event_key"`
	EventResourceHint pgtype.Text        `json:"event_resource_hint"`
	ReadableDataKey   string             `json:"readable_data_key"`
	Expression        pgtype.Text        `json:"expression"`
}

type ListMatchConditionsForEventWithHintParams struct {
	Tenantid           pgtype.UUID `json:"tenantid"`
	Eventtype          V1EventType `json:"eventtype"`
	Eventkeys          []string    `json:"eventkeys"`
	Eventresourcehints []string    `json:"eventresourcehints"`
}

type ListMatchConditionsForEventWithoutHintParams struct {
	Tenantid  pgtype.UUID `json:"tenantid"`
	Eventtype V1EventType `json:"eventtype"`
	Eventkeys []string    `json:"eventkeys"`
}

type ListMatchingSignalEventsParams struct {
	Tenantid        pgtype.UUID          `json:"tenantid"`
	Eventtype       V1TaskEventType      `json:"eventtype"`
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Eventkeys       []string             `json:"eventkeys"`
}

type ListMatchingTaskEventsParams struct {
	Tenantid        pgtype.UUID   `json:"tenantid"`
	Taskexternalids []pgtype.UUID `json:"taskexternalids"`
	Eventtypes      [][]string    `json:"eventtypes"`
}

type ListMatchingTaskEventsRow struct {
	ExternalID     pgtype.UUID        `json:"external_id"`
	ID             int64              `json:"id"`
	TenantID       pgtype.UUID        `json:"tenant_id"`
	TaskID         int64              `json:"task_id"`
	TaskInsertedAt pgtype.Timestamptz `json:"task_inserted_at"`
	RetryCount     int32              `json:"retry_count"`
	EventType      V1TaskEventType    `json:"event_type"`
	EventKey       pgtype.Text        `json:"event_key"`
	CreatedAt      pgtype.Timestamp   `json:"created_at"`
	Data           []byte             `json:"data"`
}

type ListOLAPPartitionsBeforeDateParams struct {
	Shouldpartitioneventstables bool        `json:"shouldpartitioneventstables"`
	Date                        pgtype.Date `json:"date"`
}

type ListOLAPPartitionsBeforeDateRow struct {
	ParentTable   string `json:"parent_table"`
	PartitionName string `json:"partition_name"`
}

type ListPartitionsBeforeDateRow struct {
	ParentTable   string `json:"parent_table"`
	PartitionName string `json:"partition_name"`
}

type ListQueueItemsForQueueParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Queue    string      `json:"queue"`
	GtId     pgtype.Int8 `json:"gtId"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListRateLimitsForStepsParams struct {
	Stepids  []pgtype.UUID `json:"stepids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ListRateLimitsForTenantNoMutateParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Search   pgtype.Text `json:"search"`
	Offset   interface{} `json:"offset"`
	Limit    interface{} `json:"limit"`
}

type ListRateLimitsForTenantNoMutateRow struct {
	TenantId   pgtype.UUID      `json:"tenantId"`
	Key        string           `json:"key"`
	LimitValue int32            `json:"limitValue"`
	Value      int32            `json:"value"`
	Window     string           `json:"window"`
	LastRefill pgtype.Timestamp `json:"lastRefill"`
}

type ListRateLimitsForTenantWithMutateRow struct {
	TenantId     pgtype.UUID      `json:"tenantId"`
	Key          string           `json:"key"`
	LimitValue   int32            `json:"limitValue"`
	Value        int32            `json:"value"`
	Window       string           `json:"window"`
	LastRefill   pgtype.Timestamp `json:"lastRefill"`
	NextRefillAt pgtype.Timestamp `json:"nextRefillAt"`
}

type ListSemaphoreSlotsWithStateForWorkerParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Workerid pgtype.UUID `json:"workerid"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListSemaphoreSlotsWithStateForWorkerRow struct {
	TaskID                       int64              `json:"task_id"`
	TaskInsertedAt               pgtype.Timestamptz `json:"task_inserted_at"`
	RetryCount                   int32              `json:"retry_count"`
	WorkerID                     pgtype.UUID        `json:"worker_id"`
	TenantID                     pgtype.UUID        `json:"tenant_id"`
	TimeoutAt                    pgtype.Timestamp   `json:"timeout_at"`
	ID                           int64              `json:"id"`
	InsertedAt                   pgtype.Timestamptz `json:"inserted_at"`
	TenantID_2                   pgtype.UUID        `json:"tenant_id_2"`
	Queue                        string             `json:"queue"`
	ActionID                     string             `json:"action_id"`
	StepID                       pgtype.UUID        `json:"step_id"`
	StepReadableID               string             `json:"step_readable_id"`
	WorkflowID                   pgtype.UUID        `json:"workflow_id"`
	WorkflowVersionID            pgtype.UUID        `json:"workflow_version_id"`
	WorkflowRunID                pgtype.UUID        `json:"workflow_run_id"`
	ScheduleTimeout              string             `json:"schedule_timeout"`
	StepTimeout                  pgtype.Text        `json:"step_timeout"`
	Priority                     pgtype.Int4        `json:"priority"`
	Sticky                       V1StickyStrategy   `json:"sticky"`
	DesiredWorkerID              pgtype.UUID        `json:"desired_worker_id"`
	ExternalID                   pgtype.UUID        `json:"external_id"`
	DisplayName                  string             `json:"display_name"`
	Input                        []byte             `json:"input"`
	RetryCount_2                 int32              `json:"retry_count_2"`
	InternalRetryCount           int32              `json:"internal_retry_count"`
	AppRetryCount                int32              `json:"app_retry_count"`
	StepIndex                    int64              `json:"step_index"`
	AdditionalMetadata           []byte             `json:"additional_metadata"`
	DagID                        pgtype.Int8        `json:"dag_id"`
	DagInsertedAt                pgtype.Timestamptz `json:"dag_inserted_at"`
	ParentTaskExternalID         pgtype.UUID        `json:"parent_task_external_id"`
	ParentTaskID                 pgtype.Int8        `json:"parent_task_id"`
	ParentTaskInsertedAt         pgtype.Timestamptz `json:"parent_task_inserted_at"`
	ChildIndex                   pgtype.Int8        `json:"child_index"`
	ChildKey                     pgtype.Text        `json:"child_key"`
	InitialState                 V1TaskInitialState `json:"initial_state"`
	InitialStateReason           pgtype.Text        `json:"initial_state_reason"`
	ConcurrencyParentStrategyIds []pgtype.Int8      `json:"concurrency_parent_strategy_ids"`
	ConcurrencyStrategyIds       []int64            `json:"concurrency_strategy_ids"`
	ConcurrencyKeys              []string           `json:"concurrency_keys"`
	RetryBackoffFactor           pgtype.Float8      `json:"retry_backoff_factor"`
	RetryMaxBackoff              pgtype.Int4        `json:"retry_max_backoff"`
}

type ListStepMatchConditionsParams struct {
	Stepids  []pgtype.UUID `json:"stepids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ListStepsByIdsParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ListStepsByIdsRow struct {
	ID                    pgtype.UUID        `json:"id"`
	CreatedAt             pgtype.Timestamp   `json:"createdAt"`
	UpdatedAt             pgtype.Timestamp   `json:"updatedAt"`
	DeletedAt             pgtype.Timestamp   `json:"deletedAt"`
	ReadableId            pgtype.Text        `json:"readableId"`
	TenantId              pgtype.UUID        `json:"tenantId"`
	JobId                 pgtype.UUID        `json:"jobId"`
	ActionId              string             `json:"actionId"`
	Timeout               pgtype.Text        `json:"timeout"`
	CustomUserData        []byte             `json:"customUserData"`
	Retries               int32              `json:"retries"`
	RetryBackoffFactor    pgtype.Float8      `json:"retryBackoffFactor"`
	RetryMaxBackoff       pgtype.Int4        `json:"retryMaxBackoff"`
	ScheduleTimeout       string             `json:"scheduleTimeout"`
	WorkflowVersionId     pgtype.UUID        `json:"workflowVersionId"`
	WorkflowVersionSticky NullStickyStrategy `json:"workflowVersionSticky"`
	WorkflowName          string             `json:"workflowName"`
	WorkflowId            pgtype.UUID        `json:"workflowId"`
	DefaultPriority       int32              `json:"defaultPriority"`
	ExprCount             int64              `json:"exprCount"`
	ConcurrencyCount      int64              `json:"concurrencyCount"`
}

type ListStepsByWorkflowVersionIdsParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ListStepsByWorkflowVersionIdsRow struct {
	ID                  pgtype.UUID      `json:"id"`
	CreatedAt           pgtype.Timestamp `json:"createdAt"`
	UpdatedAt           pgtype.Timestamp `json:"updatedAt"`
	DeletedAt           pgtype.Timestamp `json:"deletedAt"`
	ReadableId          pgtype.Text      `json:"readableId"`
	TenantId            pgtype.UUID      `json:"tenantId"`
	JobId               pgtype.UUID      `json:"jobId"`
	ActionId            string           `json:"actionId"`
	Timeout             pgtype.Text      `json:"timeout"`
	CustomUserData      []byte           `json:"customUserData"`
	Retries             int32            `json:"retries"`
	RetryBackoffFactor  pgtype.Float8    `json:"retryBackoffFactor"`
	RetryMaxBackoff     pgtype.Int4      `json:"retryMaxBackoff"`
	ScheduleTimeout     string           `json:"scheduleTimeout"`
	WorkflowVersionId   pgtype.UUID      `json:"workflowVersionId"`
	WorkflowName        string           `json:"workflowName"`
	WorkflowId          pgtype.UUID      `json:"workflowId"`
	JobKind             JobKind          `json:"jobKind"`
	MatchConditionCount int64            `json:"matchConditionCount"`
	Parents             []pgtype.UUID    `json:"parents"`
}

type ListTaskEventsForWorkflowRunParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type ListTaskEventsForWorkflowRunRow struct {
	TenantID               pgtype.UUID          `json:"tenant_id"`
	TaskID                 int64                `json:"task_id"`
	TaskInsertedAt         pgtype.Timestamptz   `json:"task_inserted_at"`
	RetryCount             int32                `json:"retry_count"`
	EventType              V1EventTypeOlap      `json:"event_type"`
	TimeFirstSeen          pgtype.Timestamptz   `json:"time_first_seen"`
	TimeLastSeen           pgtype.Timestamptz   `json:"time_last_seen"`
	Count                  int64                `json:"count"`
	ID                     int64                `json:"id"`
	EventTimestamp         pgtype.Timestamptz   `json:"event_timestamp"`
	ReadableStatus         V1ReadableStatusOlap `json:"readable_status"`
	ErrorMessage           pgtype.Text          `json:"error_message"`
	Output                 []byte               `json:"output"`
	WorkerID               pgtype.UUID          `json:"worker_id"`
	AdditionalEventData    pgtype.Text          `json:"additional__event_data"`
	AdditionalEventMessage pgtype.Text          `json:"additional__event_message"`
	DisplayName            string               `json:"display_name"`
	TaskExternalID         pgtype.UUID          `json:"task_external_id"`
}

type ListTaskEventsParams struct {
	Tenantid       pgtype.UUID        `json:"tenantid"`
	Taskid         int64              `json:"taskid"`
	Taskinsertedat pgtype.Timestamptz `json:"taskinsertedat"`
}

type ListTaskEventsRow struct {
	TenantID               pgtype.UUID          `json:"tenant_id"`
	TaskID                 int64                `json:"task_id"`
	TaskInsertedAt         pgtype.Timestamptz   `json:"task_inserted_at"`
	RetryCount             int32                `json:"retry_count"`
	EventType              V1EventTypeOlap      `json:"event_type"`
	TimeFirstSeen          interface{}          `json:"time_first_seen"`
	TimeLastSeen           interface{}          `json:"time_last_seen"`
	Count                  int64                `json:"count"`
	ID                     int64                `json:"id"`
	EventTimestamp         pgtype.Timestamptz   `json:"event_timestamp"`
	ReadableStatus         V1ReadableStatusOlap `json:"readable_status"`
	ErrorMessage           pgtype.Text          `json:"error_message"`
	Output                 []byte               `json:"output"`
	WorkerID               pgtype.UUID          `json:"worker_id"`
	AdditionalEventData    pgtype.Text          `json:"additional__event_data"`
	AdditionalEventMessage pgtype.Text          `json:"additional__event_message"`
}

type ListTaskExpressionEvalsParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
}

type ListTaskMetasParams struct {
	TenantID pgtype.UUID `json:"tenant_id"`
	Ids      []int64     `json:"ids"`
}

type ListTaskMetasRow struct {
	ID            int64              `json:"id"`
	InsertedAt    pgtype.Timestamptz `json:"inserted_at"`
	ExternalID    pgtype.UUID        `json:"external_id"`
	RetryCount    int32              `json:"retry_count"`
	WorkflowID    pgtype.UUID        `json:"workflow_id"`
	WorkflowRunID pgtype.UUID        `json:"workflow_run_id"`
}

type ListTaskParentOutputsParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Tenantid        pgtype.UUID          `json:"tenantid"`
}

type ListTaskParentOutputsRow struct {
	ID             int64              `json:"id"`
	InsertedAt     pgtype.Timestamptz `json:"inserted_at"`
	RetryCount     int32              `json:"retry_count"`
	TenantID       pgtype.UUID        `json:"tenant_id"`
	DagID          pgtype.Int8        `json:"dag_id"`
	DagInsertedAt  pgtype.Timestamptz `json:"dag_inserted_at"`
	StepReadableID string             `json:"step_readable_id"`
	WorkflowRunID  pgtype.UUID        `json:"workflow_run_id"`
	StepID         pgtype.UUID        `json:"step_id"`
	WorkflowID     pgtype.UUID        `json:"workflow_id"`
	Output         []byte             `json:"output"`
}

type ListTasksByDAGIdsParams struct {
	Dagids   []pgtype.UUID `json:"dagids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ListTasksByDAGIdsRow struct {
	DagID          int64              `json:"dag_id"`
	DagInsertedAt  pgtype.Timestamptz `json:"dag_inserted_at"`
	TaskID         int64              `json:"task_id"`
	TaskInsertedAt pgtype.Timestamptz `json:"task_inserted_at"`
	DagExternalID  pgtype.UUID        `json:"dag_external_id"`
}

type ListTasksByExternalIdsParams struct {
	Externalids []pgtype.UUID `json:"externalids"`
	Tenantid    pgtype.UUID   `json:"tenantid"`
}

type ListTasksByExternalIdsRow struct {
	TenantID   pgtype.UUID        `json:"tenant_id"`
	TaskID     pgtype.Int8        `json:"task_id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
}

type ListTasksForReplayParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Tenantid        pgtype.UUID          `json:"tenantid"`
}

type ListTasksForReplayRow struct {
	ID                   int64              `json:"id"`
	InsertedAt           pgtype.Timestamptz `json:"inserted_at"`
	RetryCount           int32              `json:"retry_count"`
	DagID                pgtype.Int8        `json:"dag_id"`
	DagInsertedAt        pgtype.Timestamptz `json:"dag_inserted_at"`
	StepReadableID       string             `json:"step_readable_id"`
	StepID               pgtype.UUID        `json:"step_id"`
	WorkflowID           pgtype.UUID        `json:"workflow_id"`
	ExternalID           pgtype.UUID        `json:"external_id"`
	Input                []byte             `json:"input"`
	AdditionalMetadata   []byte             `json:"additional_metadata"`
	ParentTaskExternalID pgtype.UUID        `json:"parent_task_external_id"`
	ParentTaskID         pgtype.Int8        `json:"parent_task_id"`
	ParentTaskInsertedAt pgtype.Timestamptz `json:"parent_task_inserted_at"`
	StepIndex            int64              `json:"step_index"`
	ChildIndex           pgtype.Int8        `json:"child_index"`
	ChildKey             pgtype.Text        `json:"child_key"`
	JobKind              JobKind            `json:"jobKind"`
	Parents              []pgtype.UUID      `json:"parents"`
}

type ListTasksOlapParams struct {
	Tenantid                  pgtype.UUID        `json:"tenantid"`
	Since                     pgtype.Timestamptz `json:"since"`
	Statuses                  []string           `json:"statuses"`
	Until                     pgtype.Timestamptz `json:"until"`
	WorkflowIds               []pgtype.UUID      `json:"workflowIds"`
	WorkerId                  pgtype.UUID        `json:"workerId"`
	Keys                      []string           `json:"keys"`
	Values                    []string           `json:"values"`
	Taskoffset                int32              `json:"taskoffset"`
	Tasklimit                 int32              `json:"tasklimit"`
	TriggeringEventExternalId pgtype.UUID        `json:"triggeringEventExternalId"`
}

type ListTasksOlapRow struct {
	ID         int64              `json:"id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
}

type ListTasksParams struct {
	TenantID pgtype.UUID `json:"tenant_id"`
	Ids      []int64     `json:"ids"`
}

type ListTasksToReassignParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListTasksToReassignRow struct {
	ID         int64              `json:"id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
	RetryCount int32              `json:"retry_count"`
}

type ListTasksToTimeoutParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListTasksToTimeoutRow struct {
	ID                 int64              `json:"id"`
	InsertedAt         pgtype.Timestamptz `json:"inserted_at"`
	RetryCount         int32              `json:"retry_count"`
	StepID             pgtype.UUID        `json:"step_id"`
	ExternalID         pgtype.UUID        `json:"external_id"`
	WorkflowRunID      pgtype.UUID        `json:"workflow_run_id"`
	StepTimeout        pgtype.Text        `json:"step_timeout"`
	AppRetryCount      int32              `json:"app_retry_count"`
	RetryBackoffFactor pgtype.Float8      `json:"retry_backoff_factor"`
	RetryMaxBackoff    pgtype.Int4        `json:"retry_max_backoff"`
	WorkerID           pgtype.UUID        `json:"worker_id"`
}

type ListWebhooksParams struct {
	Tenantid      pgtype.UUID                   `json:"tenantid"`
	Sourcenames   []V1IncomingWebhookSourceName `json:"sourcenames"`
	Webhooknames  []string                      `json:"webhooknames"`
	WebhookOffset pgtype.Int8                   `json:"webhookOffset"`
	WebhookLimit  pgtype.Int8                   `json:"webhookLimit"`
}

type ListWorkersWithSlotCountParams struct {
	Tenantid           pgtype.UUID      `json:"tenantid"`
	ActionId           pgtype.Text      `json:"actionId"`
	LastHeartbeatAfter pgtype.Timestamp `json:"lastHeartbeatAfter"`
	Assignable         pgtype.Bool      `json:"assignable"`
}

type ListWorkersWithSlotCountRow struct {
	Worker         Worker      `json:"worker"`
	WebhookUrl     pgtype.Text `json:"webhookUrl"`
	WebhookId      pgtype.UUID `json:"webhookId"`
	RemainingSlots int32       `json:"remainingSlots"`
}

type ListWorkflowNamesByIdsRow struct {
	ID   pgtype.UUID `json:"id"`
	Name string      `json:"name"`
}

type ListWorkflowRunDisplayNamesParams struct {
	Externalids []pgtype.UUID `json:"externalids"`
	Tenantid    pgtype.UUID   `json:"tenantid"`
}

type ListWorkflowRunDisplayNamesRow struct {
	ExternalID  pgtype.UUID        `json:"external_id"`
	DisplayName string             `json:"display_name"`
	InsertedAt  pgtype.Timestamptz `json:"inserted_at"`
}

type ListWorkflowsByNamesParams struct {
	Tenantid      pgtype.UUID `json:"tenantid"`
	Workflownames []string    `json:"workflownames"`
}

type ListWorkflowsByNamesRow struct {
	WorkflowId        pgtype.UUID `json:"workflowId"`
	WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
	WorkflowName      string      `json:"workflowName"`
}

type ListWorkflowsForEventsParams struct {
	Tenantid  pgtype.UUID `json:"tenantid"`
	Eventkeys []string    `json:"eventkeys"`
}

type ListWorkflowsForEventsRow struct {
	WorkflowVersionId                 pgtype.UUID `json:"workflowVersionId"`
	WorkflowId                        pgtype.UUID `json:"workflowId"`
	WorkflowName                      string      `json:"workflowName"`
	WorkflowTriggeringEventKeyPattern string      `json:"workflowTriggeringEventKeyPattern"`
	IncomingEventKey                  string      `json:"incomingEventKey"`
}

type LockDAGsForReplayParams struct {
	Dagids   []int64     `json:"dagids"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type LockSignalCreatedEventsParams struct {
	Taskids         []int64              `json:"taskids"`
	Taskinsertedats []pgtype.Timestamptz `json:"taskinsertedats"`
	Eventkeys       []string             `json:"eventkeys"`
	Tenantid        pgtype.UUID          `json:"tenantid"`
}

type LockSignalCreatedEventsRow struct {
	ID       int64       `json:"id"`
	EventKey pgtype.Text `json:"event_key"`
	Data     []byte      `json:"data"`
}

type LogLine struct {
	ID        int64            `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	StepRunId pgtype.UUID      `json:"stepRunId"`
	Message   string           `json:"message"`
	Level     LogLineLevel     `json:"level"`
	Metadata  []byte           `json:"metadata"`
}

type LogLineLevel string

type LookupExternalIdsParams struct {
	Externalids []pgtype.UUID `json:"externalids"`
	Tenantid    pgtype.UUID   `json:"tenantid"`
}

type ManualSlotReleaseParams struct {
	Externalid pgtype.UUID `json:"externalid"`
	Tenantid   pgtype.UUID `json:"tenantid"`
}

type MessageQueue struct {
	Name                string           `json:"name"`
	LastActive          pgtype.Timestamp `json:"lastActive"`
	Durable             bool             `json:"durable"`
	AutoDeleted         bool             `json:"autoDeleted"`
	Exclusive           bool             `json:"exclusive"`
	ExclusiveConsumerId pgtype.UUID      `json:"exclusiveConsumerId"`
}

type MessageQueueItem struct {
	ID        int64                  `json:"id"`
	Payload   []byte                 `json:"payload"`
	ReadAfter pgtype.Timestamp       `json:"readAfter"`
	ExpiresAt pgtype.Timestamp       `json:"expiresAt"`
	QueueId   pgtype.Text            `json:"queueId"`
	Status    MessageQueueItemStatus `json:"status"`
}

type MessageQueueItemStatus string

type MoveCronTriggerToNewWorkflowTriggersParams struct {
	Newworkflowtriggerid pgtype.UUID `json:"newworkflowtriggerid"`
	Oldworkflowversionid pgtype.UUID `json:"oldworkflowversionid"`
}

type MoveRateLimitedQueueItemsParams struct {
	Ids          []int64              `json:"ids"`
	Requeueafter []pgtype.Timestamptz `json:"requeueafter"`
}

type MoveRateLimitedQueueItemsRow struct {
	TenantID       pgtype.UUID        `json:"tenant_id"`
	TaskID         int64              `json:"task_id"`
	TaskInsertedAt pgtype.Timestamptz `json:"task_inserted_at"`
	RetryCount     int32              `json:"retry_count"`
}

type MoveScheduledTriggerToNewWorkflowTriggersParams struct {
	Newworkflowtriggerid pgtype.UUID `json:"newworkflowtriggerid"`
	Oldworkflowversionid pgtype.UUID `json:"oldworkflowversionid"`
}

type NullConcurrencyLimitStrategy struct {
	ConcurrencyLimitStrategy ConcurrencyLimitStrategy `json:"ConcurrencyLimitStrategy"`
	Valid                    bool                     `json:"valid"` // Valid is true if ConcurrencyLimitStrategy is not NULL
}

type NullInternalQueue struct {
	InternalQueue InternalQueue `json:"InternalQueue"`
	Valid         bool          `json:"valid"` // Valid is true if InternalQueue is not NULL
}

type NullInviteLinkStatus struct {
	InviteLinkStatus InviteLinkStatus `json:"InviteLinkStatus"`
	Valid            bool             `json:"valid"` // Valid is true if InviteLinkStatus is not NULL
}

type NullJobKind struct {
	JobKind JobKind `json:"JobKind"`
	Valid   bool    `json:"valid"` // Valid is true if JobKind is not NULL
}

type NullJobRunStatus struct {
	JobRunStatus JobRunStatus `json:"JobRunStatus"`
	Valid        bool         `json:"valid"` // Valid is true if JobRunStatus is not NULL
}

type NullLeaseKind struct {
	LeaseKind LeaseKind `json:"LeaseKind"`
	Valid     bool      `json:"valid"` // Valid is true if LeaseKind is not NULL
}

type NullLimitResource struct {
	LimitResource LimitResource `json:"LimitResource"`
	Valid         bool          `json:"valid"` // Valid is true if LimitResource is not NULL
}

type NullLogLineLevel struct {
	LogLineLevel LogLineLevel `json:"LogLineLevel"`
	Valid        bool         `json:"valid"` // Valid is true if LogLineLevel is not NULL
}

type NullMessageQueueItemStatus struct {
	MessageQueueItemStatus MessageQueueItemStatus `json:"MessageQueueItemStatus"`
	Valid                  bool                   `json:"valid"` // Valid is true if MessageQueueItemStatus is not NULL
}

type NullStepExpressionKind struct {
	StepExpressionKind StepExpressionKind `json:"StepExpressionKind"`
	Valid              bool               `json:"valid"` // Valid is true if StepExpressionKind is not NULL
}

type NullStepRateLimitKind struct {
	StepRateLimitKind StepRateLimitKind `json:"StepRateLimitKind"`
	Valid             bool              `json:"valid"` // Valid is true if StepRateLimitKind is not NULL
}

type NullStepRunEventReason struct {
	StepRunEventReason StepRunEventReason `json:"StepRunEventReason"`
	Valid              bool               `json:"valid"` // Valid is true if StepRunEventReason is not NULL
}

type NullStepRunEventSeverity struct {
	StepRunEventSeverity StepRunEventSeverity `json:"StepRunEventSeverity"`
	Valid                bool                 `json:"valid"` // Valid is true if StepRunEventSeverity is not NULL
}

type NullStepRunStatus struct {
	StepRunStatus StepRunStatus `json:"StepRunStatus"`
	Valid         bool          `json:"valid"` // Valid is true if StepRunStatus is not NULL
}

type NullStickyStrategy struct {
	StickyStrategy StickyStrategy `json:"StickyStrategy"`
	Valid          bool           `json:"valid"` // Valid is true if StickyStrategy is not NULL
}

type NullTenantMajorEngineVersion struct {
	TenantMajorEngineVersion TenantMajorEngineVersion `json:"TenantMajorEngineVersion"`
	Valid                    bool                     `json:"valid"` // Valid is true if TenantMajorEngineVersion is not NULL
}

type NullTenantMajorUIVersion struct {
	TenantMajorUIVersion TenantMajorUIVersion `json:"TenantMajorUIVersion"`
	Valid                bool                 `json:"valid"` // Valid is true if TenantMajorUIVersion is not NULL
}

type NullTenantMemberRole struct {
	TenantMemberRole TenantMemberRole `json:"TenantMemberRole"`
	Valid            bool             `json:"valid"` // Valid is true if TenantMemberRole is not NULL
}

type NullTenantResourceLimitAlertType struct {
	TenantResourceLimitAlertType TenantResourceLimitAlertType `json:"TenantResourceLimitAlertType"`
	Valid                        bool                         `json:"valid"` // Valid is true if TenantResourceLimitAlertType is not NULL
}

type NullV1CelEvaluationFailureSource struct {
	V1CelEvaluationFailureSource V1CelEvaluationFailureSource `json:"v1_cel_evaluation_failure_source"`
	Valid                        bool                         `json:"valid"` // Valid is true if V1CelEvaluationFailureSource is not NULL
}

type NullV1ConcurrencyStrategy struct {
	V1ConcurrencyStrategy V1ConcurrencyStrategy `json:"v1_concurrency_strategy"`
	Valid                 bool                  `json:"valid"` // Valid is true if V1ConcurrencyStrategy is not NULL
}

type NullV1EventType struct {
	V1EventType V1EventType `json:"v1_event_type"`
	Valid       bool        `json:"valid"` // Valid is true if V1EventType is not NULL
}

type NullV1EventTypeOlap struct {
	V1EventTypeOlap V1EventTypeOlap `json:"v1_event_type_olap"`
	Valid           bool            `json:"valid"` // Valid is true if V1EventTypeOlap is not NULL
}

type NullV1IncomingWebhookAuthType struct {
	V1IncomingWebhookAuthType V1IncomingWebhookAuthType `json:"v1_incoming_webhook_auth_type"`
	Valid                     bool                      `json:"valid"` // Valid is true if V1IncomingWebhookAuthType is not NULL
}

type NullV1IncomingWebhookHmacAlgorithm struct {
	V1IncomingWebhookHmacAlgorithm V1IncomingWebhookHmacAlgorithm `json:"v1_incoming_webhook_hmac_algorithm"`
	Valid                          bool                           `json:"valid"` // Valid is true if V1IncomingWebhookHmacAlgorithm is not NULL
}

type NullV1IncomingWebhookHmacEncoding struct {
	V1IncomingWebhookHmacEncoding V1IncomingWebhookHmacEncoding `json:"v1_incoming_webhook_hmac_encoding"`
	Valid                         bool                          `json:"valid"` // Valid is true if V1IncomingWebhookHmacEncoding is not NULL
}

type NullV1IncomingWebhookSourceName struct {
	V1IncomingWebhookSourceName V1IncomingWebhookSourceName `json:"v1_incoming_webhook_source_name"`
	Valid                       bool                        `json:"valid"` // Valid is true if V1IncomingWebhookSourceName is not NULL
}

type NullV1LogLineLevel struct {
	V1LogLineLevel V1LogLineLevel `json:"v1_log_line_level"`
	Valid          bool           `json:"valid"` // Valid is true if V1LogLineLevel is not NULL
}

type NullV1MatchConditionAction struct {
	V1MatchConditionAction V1MatchConditionAction `json:"v1_match_condition_action"`
	Valid                  bool                   `json:"valid"` // Valid is true if V1MatchConditionAction is not NULL
}

type NullV1MatchKind struct {
	V1MatchKind V1MatchKind `json:"v1_match_kind"`
	Valid       bool        `json:"valid"` // Valid is true if V1MatchKind is not NULL
}

type NullV1ReadableStatusOlap struct {
	V1ReadableStatusOlap V1ReadableStatusOlap `json:"v1_readable_status_olap"`
	Valid                bool                 `json:"valid"` // Valid is true if V1ReadableStatusOlap is not NULL
}

type NullV1RunKind struct {
	V1RunKind V1RunKind `json:"v1_run_kind"`
	Valid     bool      `json:"valid"` // Valid is true if V1RunKind is not NULL
}

type NullV1StatusKind struct {
	V1StatusKind V1StatusKind `json:"v1_status_kind"`
	Valid        bool         `json:"valid"` // Valid is true if V1StatusKind is not NULL
}

type NullV1StepMatchConditionKind struct {
	V1StepMatchConditionKind V1StepMatchConditionKind `json:"v1_step_match_condition_kind"`
	Valid                    bool                     `json:"valid"` // Valid is true if V1StepMatchConditionKind is not NULL
}

type NullV1StickyStrategy struct {
	V1StickyStrategy V1StickyStrategy `json:"v1_sticky_strategy"`
	Valid            bool             `json:"valid"` // Valid is true if V1StickyStrategy is not NULL
}

type NullV1StickyStrategyOlap struct {
	V1StickyStrategyOlap V1StickyStrategyOlap `json:"v1_sticky_strategy_olap"`
	Valid                bool                 `json:"valid"` // Valid is true if V1StickyStrategyOlap is not NULL
}

type NullV1TaskEventType struct {
	V1TaskEventType V1TaskEventType `json:"v1_task_event_type"`
	Valid           bool            `json:"valid"` // Valid is true if V1TaskEventType is not NULL
}

type NullV1TaskInitialState struct {
	V1TaskInitialState V1TaskInitialState `json:"v1_task_initial_state"`
	Valid              bool               `json:"valid"` // Valid is true if V1TaskInitialState is not NULL
}

type NullVcsProvider struct {
	VcsProvider VcsProvider `json:"VcsProvider"`
	Valid       bool        `json:"valid"` // Valid is true if VcsProvider is not NULL
}

type NullWebhookWorkerRequestMethod struct {
	WebhookWorkerRequestMethod WebhookWorkerRequestMethod `json:"WebhookWorkerRequestMethod"`
	Valid                      bool                       `json:"valid"` // Valid is true if WebhookWorkerRequestMethod is not NULL
}

type NullWorkerLabelComparator struct {
	WorkerLabelComparator WorkerLabelComparator `json:"WorkerLabelComparator"`
	Valid                 bool                  `json:"valid"` // Valid is true if WorkerLabelComparator is not NULL
}

type NullWorkerSDKS struct {
	WorkerSDKS WorkerSDKS `json:"WorkerSDKS"`
	Valid      bool       `json:"valid"` // Valid is true if WorkerSDKS is not NULL
}

type NullWorkerType struct {
	WorkerType WorkerType `json:"WorkerType"`
	Valid      bool       `json:"valid"` // Valid is true if WorkerType is not NULL
}

type NullWorkflowKind struct {
	WorkflowKind WorkflowKind `json:"WorkflowKind"`
	Valid        bool         `json:"valid"` // Valid is true if WorkflowKind is not NULL
}

type NullWorkflowRunStatus struct {
	WorkflowRunStatus WorkflowRunStatus `json:"WorkflowRunStatus"`
	Valid             bool              `json:"valid"` // Valid is true if WorkflowRunStatus is not NULL
}

type NullWorkflowTriggerCronRefMethods struct {
	WorkflowTriggerCronRefMethods WorkflowTriggerCronRefMethods `json:"WorkflowTriggerCronRefMethods"`
	Valid                         bool                          `json:"valid"` // Valid is true if WorkflowTriggerCronRefMethods is not NULL
}

type NullWorkflowTriggerScheduledRefMethods struct {
	WorkflowTriggerScheduledRefMethods WorkflowTriggerScheduledRefMethods `json:"WorkflowTriggerScheduledRefMethods"`
	Valid                              bool                               `json:"valid"` // Valid is true if WorkflowTriggerScheduledRefMethods is not NULL
}

type PopDurableSleepParams struct {
	TenantID pgtype.UUID `json:"tenant_id"`
	Limit    pgtype.Int4 `json:"limit"`
}

type PopulateDAGMetadataParams struct {
	Includepayloads bool               `json:"includepayloads"`
	ID              int64              `json:"id"`
	Insertedat      pgtype.Timestamptz `json:"insertedat"`
	Tenantid        pgtype.UUID        `json:"tenantid"`
}

type PopulateDAGMetadataRow struct {
	DagID                int64                `json:"dag_id"`
	RunID                int64                `json:"run_id"`
	TenantID             pgtype.UUID          `json:"tenant_id"`
	InsertedAt           pgtype.Timestamptz   `json:"inserted_at"`
	ExternalID           pgtype.UUID          `json:"external_id"`
	ReadableStatus       V1ReadableStatusOlap `json:"readable_status"`
	Kind                 V1RunKind            `json:"kind"`
	WorkflowID           pgtype.UUID          `json:"workflow_id"`
	DisplayName          string               `json:"display_name"`
	Input                []byte               `json:"input"`
	AdditionalMetadata   []byte               `json:"additional_metadata"`
	WorkflowVersionID    pgtype.UUID          `json:"workflow_version_id"`
	ParentTaskExternalID pgtype.UUID          `json:"parent_task_external_id"`
	CreatedAt            pgtype.Timestamptz   `json:"created_at"`
	StartedAt            pgtype.Timestamptz   `json:"started_at"`
	FinishedAt           pgtype.Timestamptz   `json:"finished_at"`
	ErrorMessage         string               `json:"error_message"`
	Output               []byte               `json:"output"`
	RetryCount           int32                `json:"retry_count"`
}