Push

id: faktory_push
namespace: company.team

inputs:
  - id: email
    type: STRING

tasks:
  - id: enqueue_welcome_email
    type: io.kestra.plugin.faktory.Push
    host: "{{ secret('FAKTORY_HOST') }}"
    password: "{{ secret('FAKTORY_PASSWORD') }}"
    jobType: SendWelcomeEmail
    queue: mailers
    args:
      - "{{ inputs.email }}"

id: faktory_scheduled_push
namespace: company.team

tasks:
  - id: schedule_report
    type: io.kestra.plugin.faktory.Push
    host: "{{ secret('FAKTORY_HOST') }}"
    password: "{{ secret('FAKTORY_PASSWORD') }}"
    jobType: GenerateNightlyReport
    args:
      - "2026-07-10"
    at: "{{ now() | dateAdd(1, 'DAYS') }}"
    retries: 5
    custom:
      source: kestra

  - id: log_jid
    type: io.kestra.plugin.core.log.Log
    message: "Enqueued Faktory job {{ outputs.schedule_report.jid }}"