A package for tracking queue job statuses in your database via Queue Hooks

What's New

Updating Statuses


Updates the package to more correctly update statuses in the database.

There is a new migration, QueueDatabaseEntryUpgradeFrom_0_2_0, that is only required if you were previously using 0.2.0.


This package adds database success and failure tracking for all dequeued jobs.


Use the SPM string to easily include the dependendency in your Package.swift file.

.package(url: "https://github.com/vapor-community/queues-database-hooks.git", from: ...)

After you have the package installed, getting started is easy:

app.queues.add(QueuesDatabaseNotificationHook.default(db: app.db))

And that's all! Your app will now start tracking job data in your specified database.

Configuring the error handler

By default, the package will attempt to transform Errors into Strings via the localizedDescription property. You can pass in a closure when initializing the QueuesDatabaseNotificationHook object to specify how to transform errors. You can also pass in a closure for transforming the notification data (if, for example, you only want to save the payload data for certain job names.)

let dbHook = QueuesDatabaseNotificationHook(db: db) { error -> (String) in
    // Do something here with `error` that returns a string
} payloadClosure: { data -> (NotificationJobData) in
    return data

What can I do with this data?

Out of the box, there's nothing built in to analyze the data that is captured. You can think of this as a "bring your own frontend" project - now that you have the data from your queue jobs you can do whatever you like with it.

That being said, there are some community projects built on top of the data that surface insights and create dashboards:

  1. https://github.com/gotranseo/queues-dash


  • Swift Tools 5.3.0
View More Packages from this Author


Last updated: Fri Mar 24 2023 18:14:31 GMT-0500 (GMT-05:00)