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: EXTRACTAfter (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