- enqueueJobs<T>(
client: SupabaseClient<
SupaworkerDatabase,
"supaworker",
{
CompositeTypes: {};
Enums: {};
Functions: {
dequeue: {
Args: { queue_name: string };
Returns: {
attempts: number;
claimed_at: null | string;
created_at: string;
id: number;
payload: Json;
queue: string;
status: string;
updated_at: string;
}[];
};
increment_attempts: {
Args: { job_id: number };
Returns: {
attempts: number;
claimed_at: null | string;
created_at: string;
id: number;
payload: Json;
queue: string;
status: string;
updated_at: string;
}[];
};
};
Tables: {
jobs: {
Insert: {
attempts?: number;
claimed_at?: null
| string;
created_at?: string;
id?: number;
payload?: Json;
queue: string;
status: string;
updated_at?: string;
};
Relationships: [];
Row: {
attempts: number;
claimed_at: null | string;
created_at: string;
id: number;
payload: Json;
queue: string;
status: string;
updated_at: string;
};
Update: {
attempts?: number;
claimed_at?: null
| string;
created_at?: string;
id?: number;
payload?: Json;
queue?: string;
status?: string;
updated_at?: string;
};
};
logs: {
Insert: {
created_at?: string;
error?: Json;
id?: number;
job_id: number;
status: string;
};
Relationships: [
{
columns: ["job_id"];
foreignKeyName: "logs_job_id_fkey";
isOneToOne: false;
referencedColumns: ["id"];
referencedRelation: "jobs";
},
];
Row: {
created_at: string;
error: Json;
id: number;
job_id: number;
status: string;
};
Update: {
created_at?: string;
error?: Json;
id?: number;
job_id?: number;
status?: string;
};
};
};
Views: {};
},
>,
jobs: JobWithPayloadInsert<T>[],
): Promise<JobWithPayload<T>[]> Parameters
- client: SupabaseClient<
SupaworkerDatabase,
"supaworker",
{
CompositeTypes: {};
Enums: {};
Functions: {
dequeue: {
Args: { queue_name: string };
Returns: {
attempts: number;
claimed_at: null | string;
created_at: string;
id: number;
payload: Json;
queue: string;
status: string;
updated_at: string;
}[];
};
increment_attempts: {
Args: { job_id: number };
Returns: {
attempts: number;
claimed_at: null | string;
created_at: string;
id: number;
payload: Json;
queue: string;
status: string;
updated_at: string;
}[];
};
};
Tables: {
jobs: {
Insert: {
attempts?: number;
claimed_at?: null
| string;
created_at?: string;
id?: number;
payload?: Json;
queue: string;
status: string;
updated_at?: string;
};
Relationships: [];
Row: {
attempts: number;
claimed_at: null | string;
created_at: string;
id: number;
payload: Json;
queue: string;
status: string;
updated_at: string;
};
Update: {
attempts?: number;
claimed_at?: null
| string;
created_at?: string;
id?: number;
payload?: Json;
queue?: string;
status?: string;
updated_at?: string;
};
};
logs: {
Insert: {
created_at?: string;
error?: Json;
id?: number;
job_id: number;
status: string;
};
Relationships: [
{
columns: ["job_id"];
foreignKeyName: "logs_job_id_fkey";
isOneToOne: false;
referencedColumns: ["id"];
referencedRelation: "jobs";
},
];
Row: {
created_at: string;
error: Json;
id: number;
job_id: number;
status: string;
};
Update: {
created_at?: string;
error?: Json;
id?: number;
job_id?: number;
status?: string;
};
};
};
Views: {};
},
> - jobs: JobWithPayloadInsert<T>[]