//this Job subscribes to an event called new.user
client.defineJob({
  id: "job-2",
  name: "Second job",
  version: "0.0.1",
  //subscribes to the "new.user" event
  trigger: eventTrigger({
    //sent events with this name will trigger this Job
    name: "new.user",
    //the expected payload shape
    schema: z.object({
      userId: z.string(),
      tier: z.union([z.literal("free"), z.literal("pro")]),
    }),
    //only events with the tier: "pro" will trigger this Job
    filter: {
      tier: ["pro"],
    },
    //(optional) example event object
    examples: [
      {
        id: "issue.opened",
        name: "Issue opened",
        payload: {
          userId: "1234",
          tier: "free",
        },
        //optional
        icon: "github",
      },
    ],
  }),
  run: async (payload, io, ctx) => {
    await io.logger.log("New pro user created", { userId: payload.userId });
    //do stuff
  },
});

There are two way to send an event that will trigger eventTrigger():

  1. Use client.sendEvent() from anywhere in your codebase.
  2. Use io.sendEvent() from inside a Job's run() function.

You can have multiple Jobs that subscribe to the same event, they will all trigger when the event gets delivered.

​
Parameters

options
object
required
name
string
required

The name of the event you are subscribing to. Must be an exact match (case sensitive).

schema
object

A Zod schema that defines the shape of the event payload. The default is z.any() which is any.

source
string

You can use this to filter events based on the source.

filter
object

Used to filter which events trigger the Job.

An example:

{
  name: ["John", "Jane"],
  age: [18, 21]
}

This filter would match against an event with the following data:

{
  "name": "Jane",
  "age": 18,
  "location": "San Francisco"
}
examples
array

Used to provide example payloads that are accepted by the job.

This will be available in the dashboard and can be used to trigger test runs.

id
string
required

The example’s ID.

name
string
required

The name that’s displayed in the dashboard.

payload
object
required

The payload that’s accepted by the job.

icon
string

The icon to use for this example in the dashboard.

Was this page helpful?

invokeTrigger()cronTrigger()