Skip to contents

For Each Task

Source: R/data-structures.R
for_each_task.Rd

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()