Function enqueueJobs

  • Type Parameters

    • 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>[]

    Returns Promise<JobWithPayload<T>[]>