Nouvelle page
Audit des jobs Bull
Config globale
BULL_DEFAULT_OPTIONS (src/utils/bull.utils.ts) :
- attempts: 5, backoff: exponential 1s
- removeOnComplete: 1 jour / 20000
- removeOnFail: 3 jours / 20000
Bull Board : /queues (auth basic)
Jobs par queue
charging-stations-processor
| Job |
Concurrency |
Lock |
Error handling |
| boot-process |
1 |
@LockByKey (30s) |
catch sans rethrow |
| set-online-status-process |
1 |
@LockByKey (30s) |
catch sans rethrow |
connectors-processor
| Job |
Concurrency |
Lock |
Error handling |
| status-notification-process |
1 |
@LockByKey (30s) |
catch sans rethrow |
Enqueue vers smart-charging-processor si smart charging actif.
transactions-processor
| Job |
Concurrency |
Lock |
Error handling |
| stop-transaction-job |
1 |
@LockByKey (30s) |
catch + rethrow |
| add-meter-value-job |
1 |
@LockByKey (30s) |
catch + rethrow |
| delete-zombie-transaction-job |
1 |
aucun |
catch sans rethrow |
| add-meter-value-ocpp20-job |
1 |
aucun |
catch sans rethrow |
ocpp-logs-processor
| Job |
Concurrency |
Lock |
Error handling |
| ocpp-logs-batch-process |
1 |
@LockByKey (30s) |
catch sans rethrow |
| ocpp-logs-process |
1 |
@LockByKey (30s) |
catch sans rethrow |
| remove-old-ocpp-logs |
1 |
aucun |
catch sans rethrow |
notifications-processor
| Job |
Concurrency |
Lock |
Error handling |
| check-charging-station-offline |
1 |
aucun |
pas de try/catch (BaseProcessor) |
| send-notification-job |
1 |
aucun |
catch sans rethrow |
| notifications-transactions-zombie |
1 |
aucun |
pas de try/catch (BaseProcessor) |
smart-charging-processor
| Job |
Concurrency |
Lock |
Error handling |
| smart-charging-on-start-job |
1 |
@SkipIfBusy (30s) |
catch sans rethrow |
| smart-charging-rebalance-job |
1 |
@SkipIfBusy (30s) |
catch sans rethrow |
| smart-charging-clear-profile-job |
3 |
@LockByKey (15s) |
catch sans rethrow |
kpi-processor
| Job |
Concurrency |
Lock |
Error handling |
| get-location-kpi-job |
1 |
aucun |
catch sans rethrow |
| get-group-kpi-job |
1 |
aucun |
catch sans rethrow (console.error) |
groups-processor
| Job |
Concurrency |
Lock |
Error handling |
| clear-profile-groups-job |
1 |
aucun |
catch sans rethrow |
| groups-tree-with-data-job |
1 |
aucun |
catch sans rethrow |
locations-processor
| Job |
Concurrency |
Lock |
Error handling |
| location-consumption-job |
1 |
aucun |
catch sans rethrow |
external-transactions-processor
| Job |
Concurrency |
Lock |
Error handling |
| save-external-transaction-job |
1 |
aucun |
catch sans rethrow |
kuantic-processor
| Job |
Concurrency |
Lock |
Error handling |
| insert-kuantic-home-transactions-job |
1 |
aucun |
catch sans rethrow |
| insert-kuantic-home-odometers-job |
1 |
aucun |
catch sans rethrow |
ocean-processor
| Job |
Concurrency |
Lock |
Error handling |
| insert-ocean-home-transactions-job |
1 |
aucun |
catch sans rethrow |
| insert-ocean-home-odometers-job |
1 |
aucun |
catch sans rethrow |
users-processor
| Job |
Concurrency |
Lock |
Error handling |
| user-send-password-email-job |
1 |
aucun |
catch sans rethrow |
teams-processor
| Job |
Concurrency |
Lock |
Error handling |
| get-teams-reporting-job |
1 |
aucun |
pas de try/catch (BaseProcessor) |
mission-processor
| Job |
Concurrency |
Lock |
Error handling |
| mission-ticket-in-progress-job |
1 |
aucun |
pas de try/catch (BaseProcessor) |
| mission-patch-material-job |
1 |
aucun |
pas de try/catch (BaseProcessor) |
qualicharge-processor
| Job |
Concurrency |
Lock |
Error handling |
| qualicharge-static-job |
1 |
aucun |
catch + rethrow |
audit-processor
| Job |
Concurrency |
Lock |
Error handling |
Options custom |
| create-audit-log-job |
1 |
aucun |
catch + rethrow |
attempts: 3, backoff: exponential 2s, removeOnFail: false |
