begin with workers. first add a cna worker

This commit is contained in:
Brendan McDevitt 2022-04-18 17:27:31 -05:00
parent 39d4b385e5
commit 6f02a95a4a
3 changed files with 29 additions and 11 deletions

View file

@ -0,0 +1,10 @@
require '/data_importer/lib/importers/cna_importer.rb'
class CnaImporterWorker
include Faktory::Job
def perform(*args)
puts "Hello, I am #{jid} with args #{args}"
CnaImporter.new.import
end
end

View file

@ -1,14 +1,9 @@
faktory: tcp://faktory:7419 faktory: tcp://faktory:7419
jobs: jobs:
- job: test - job: CnaImporterWorker
schedule: "@every 30s"
args: args:
- test - true
- job: test schedule: "@daily"
schedule: 5 * * * *
args:
- 1
- 2
retries: 1 retries: 1
queue: default queue: default
priority: 5 priority: 5

View file

@ -6,7 +6,7 @@ services:
- ./tmp/db:/var/lib/postgresql/data - ./tmp/db:/var/lib/postgresql/data
environment: environment:
POSTGRES_PASSWORD: password POSTGRES_PASSWORD: password
web: web: &web_base
build: . build: .
env_file: env_file:
- credentials.env - credentials.env
@ -15,6 +15,9 @@ services:
- .:/data_importer - .:/data_importer
ports: ports:
- "3000:3000" - "3000:3000"
environment:
FAKTORY_URL: 'tcp://faktory:7419'
FAKTORY_PROVIDER: FAKTORY_URL
depends_on: depends_on:
- db - db
faktory: faktory:
@ -24,6 +27,14 @@ services:
- "7420:7420" - "7420:7420"
volumes: volumes:
- ./tmp/faktory:/var/lib/faktory - ./tmp/faktory:/var/lib/faktory
depends_on:
- db
faktory-worker:
<<: *web_base
command: bundle exec faktory-worker
ports: []
depends_on:
- web
faktory-cron: faktory-cron:
image: cdrx/faktory-cron image: cdrx/faktory-cron
command: "./faktory-cron -config /crontab.yaml" command: "./faktory-cron -config /crontab.yaml"
@ -31,3 +42,5 @@ services:
FAKTORY_URL: 'tcp://faktory:7419' FAKTORY_URL: 'tcp://faktory:7419'
volumes: volumes:
- ./crontab.yaml:/crontab.yaml - ./crontab.yaml:/crontab.yaml
depends_on:
- faktory