توزيع المهام الديناميكي ومجموعات المهام

from datetime import datetime, timezone
from airflow.sdk import dag, task

@dag(schedule=None, start_date=datetime(2026, 1, 1, tzinfo=timezone.utc), catchup=False)
def lab_depot_map():
    @task
    def process(depot, multiplier):
        return {'depot': depot, 'units': multiplier * 2}
    process.partial(multiplier=3).expand(depot=['D1', 'D2'])

lab_depot_map()

تحدد المدخلات نسختين بست وحدات لكل منهما؛ ولا تختبر بيئة Airflow.

from itertools import product
depots = ['D1', 'D2']
dates = ['2026-10-01', '2026-10-02', '2026-10-03']
combinations = list(product(depots, dates))
pairs = list(zip(depots, dates))
assert len(combinations) == 6
assert len(pairs) == 2
print(len(combinations), len(pairs))

6 2

تختلف ستة تراكيب عن زوجين؛ فاختر مجموعة العمل صراحة.