SDK
invokeTrigger()
Use invokeTrigger()
to allow a Job to be manually triggered using Job.invoke()
//this Job subscribes to an event called new.user
export const exampleJob = client.defineJob({
id: "example-job",
name: "Example job",
version: "1.0.1",
trigger: invokeTrigger({
//the expected payload shape
schema: z.object({
userId: z.string(),
tier: z.union([z.literal("free"), z.literal("pro")]),
}),
//(optional) example payload object
examples: [
{
id: "issue.opened",
name: "Issue opened",
payload: {
userId: "1234",
tier: "free",
},
//optional
icon: "github",
},
],
}),
run: async (payload, io, ctx) => {
// do something with the payload
},
});
Setting invokeTrigger()
on a job allows you to manually trigger the job using Job.invoke()
, either from your backend or from inside another job. See our Invoke Trigger guide for more info.
Parameters
options
object
requiredschema
object
A Zod schema that defines the shape of the
job payload. The default is z.any()
which is any
. This will be used to correctly type the Job.invoke()
method.
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
requiredThe example’s ID.
name
string
requiredThe name that’s displayed in the dashboard.
payload
object
requiredThe payload that’s accepted by the job.
icon
string
The icon to use for this example in the dashboard.
Was this page helpful?
//this Job subscribes to an event called new.user
export const exampleJob = client.defineJob({
id: "example-job",
name: "Example job",
version: "1.0.1",
trigger: invokeTrigger({
//the expected payload shape
schema: z.object({
userId: z.string(),
tier: z.union([z.literal("free"), z.literal("pro")]),
}),
//(optional) example payload object
examples: [
{
id: "issue.opened",
name: "Issue opened",
payload: {
userId: "1234",
tier: "free",
},
//optional
icon: "github",
},
],
}),
run: async (payload, io, ctx) => {
// do something with the payload
},
});