Apio Gravity Client

Helps you to interact with Apio Gravity.

Usage

Package import

const GravityClient = require('@apio/gravity-worker')

.. or using ES6?

import GravityClient from '@apio/gravity-worker'

Usage

const client = new GravityClient({
  url: 'https://<my-gravity-url>',
  topic: '<my-topic>',
  scheduling: '*/5 * * * *'
})

client.on('job', async (job) => {
  console.log("New job received", job)

  // Complete with an output object
  await client.complete(job.uuid, { hello: "world" })

  // Fail with an error object
  await client.fail(job.uuid, { reason: "some_error" })

  // Return to queue as queued
  await client.return(job.uuid)
})