Condition Task
condition_task(
left,
right,
op = c("EQUAL_TO", "GREATER_THAN", "GREATER_THAN_OR_EQUAL", "LESS_THAN",
"LESS_THAN_OR_EQUAL", "NOT_EQUAL")
)
Left operand of the condition task. Either a string value or a job state or parameter reference.
Right operand of the condition task. Either a string value or a job state or parameter reference.
Operator, one of "EQUAL_TO"
, "GREATER_THAN"
,
"GREATER_THAN_OR_EQUAL"
, "LESS_THAN"
, "LESS_THAN_OR_EQUAL"
, "NOT_EQUAL"
The task evaluates a condition that can be used to control the execution of other tasks when the condition_task field is present. The condition task does not require a cluster to execute and does not support retries or notifications.
Other Task Objects:
email_notifications()
,
for_each_task()
,
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()