dispatcher.yml

# Demo config
---
version: 2
service:
  pool_kwargs:
    min_workers: 2  # subprocesses
    max_workers: 12
    scaledown_wait: 15  # seconds
  main_kwargs:
    node_id: demo-server-a
brokers:
  pg_notify:
    config:
      conninfo: dbname=dispatch_db user=dispatch password=dispatching host=localhost port=55777
    sync_connection_factory: dispatcher.brokers.pg_notify.connection_saver
    # List of channels to listen on
    channels:
    - test_channel
    - test_channel2
    - test_channel3
    default_publish_channel: test_channel
producers:
  ScheduledProducer:
    task_schedule:
      'lambda: __import__("time").sleep(1)':
        schedule: 3
      'lambda: __import__("time").sleep(2)':
        schedule: 3
  OnStartProducer:
    task_list:
      'lambda: print("This task runs on startup")': {}
publish:
  default_broker: pg_notify