josh-fell commented on code in PR #25874:
URL: https://github.com/apache/airflow/pull/25874#discussion_r951874773
##########
tests/cluster_policies/__init__.py:
##########
@@ -89,8 +89,8 @@ class TimedOperator(BaseOperator, ABC):
def task_policy(task: TimedOperator):
if task.task_type == 'HivePartitionSensor':
task.queue = "sensor_queue"
- if task.timeout > timedelta(hours=48):
Review Comment:
This is relative to the `TimedOperator` just above this policy though. The
`[START example_task_cluster_policy]` marker was moved above the
`TimedOperator` declaration in #23468 so it will show up in the Cluster Policy
doc when published. Should the `TimedOperator` piece be removed altogether
then?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
