Broadcom

Broadcom Workload Automation dSeries → Apache Airflow

Migrate Broadcom WA dSeries (formerly Jobtrac) job flows to Apache Airflow DAGs.

Broadcom Workload Automation dSeries (formerly ASG Zena / Jobtrac) is a distributed workload automation platform used primarily for Windows and Unix batch scheduling. It organizes work into job streams with predecessor/successor relationships. BatchFoundry converts dSeries job definitions and flow logic into Airflow DAGs, including agent mapping and notification policies.

Concept Mapping

Job streamDAG
JobTask / Operator
PredecessorUpstream task dependency (>>)
AgentAirflow worker queue
Schedule definitionschedule_interval
Hold / ReleaseDAG paused / manual trigger
Notificationon_failure_callback / email_on_failure
Retry on failureretries / retry_delay
Global variableAirflow Variable
File event triggerFileSensor

The Hard Parts We Handle

  • dSeries agent inventory → Airflow worker pool mapping
  • File event triggers → Airflow FileSensor
  • Schedule calendar translation
  • Cross-platform job dependencies (Windows ↔ Unix)
  • Notification and escalation policies

dSeries job stream to DAG

Before

# dSeries job stream (simplified)
JOBSTREAM: DAILY_ETL
  SCHEDULE: MON-FRI 01:00
  JOB: EXTRACT
    COMMAND: /opt/etl/extract.sh
    AGENT: UNIX-AGENT-01
  JOB: LOAD
    COMMAND: /opt/etl/load.sh
    AGENT: UNIX-AGENT-01
    PREDECESSOR: EXTRACT

After (Airflow)

# Apache Airflow DAG
from airflow.decorators import dag
from airflow.operators.bash import BashOperator
from pendulum import datetime

@dag(schedule="0 1 * * 1-5", start_date=datetime(2025,1,1), catchup=False)
def daily_etl():
    extract = BashOperator(task_id="extract", bash_command="/opt/etl/extract.sh", queue="unix-agent-01")
    load = BashOperator(task_id="load", bash_command="/opt/etl/load.sh", queue="unix-agent-01")
    extract >> load

daily_etl()

Ready to migrate from Broadcom Workload Automation dSeries?

Talk to a BatchFoundry engineer about your workload estate.

Talk to an Engineer

Related Migrations