for_each_task: For Each Task

In zacdav-db/brickster: R Toolkit for 'Databricks'

For Each Task

Description

For Each Task

Usage

for_each_task(inputs, task, concurrency = 1)

Arguments

inputs	Array for task to iterate on. This can be a JSON string or a reference to an array parameter.
task	Must be a job_task().
concurrency	Maximum allowed number of concurrent runs of the task.

See Also

Other Task Objects: condition_task(), email_notifications(), libraries(), new_cluster(), notebook_task(), pipeline_task(), python_wheel_task(), run_job_task(), spark_jar_task(), spark_python_task(), spark_submit_task(), sql_file_task(), sql_query_task()

zacdav-db/brickster documentation built on June 13, 2025, 2:39 p.m.