code: def task_policy(task: TimedOperator):
      if task.task_type == "HivePartitionSensor":
          task.queue = "sensor_queue"
      if task.timeout > timedelta(hours=48):
          task.timeout = timedelta(hours=48)
  
file_path: airflow/tests/cluster_policies/__init__.py
imports: from __future__ import annotations
  from abc import ABC
  from datetime import timedelta
  from typing import TYPE_CHECKING, Callable
  from airflow.configuration import conf
  from airflow.exceptions import AirflowClusterPolicySkipDag, AirflowClusterPolicyViolation
  from airflow.models.baseoperator import BaseOperator
label_desc: Use image node_id 5 for calling a global function with example usage: task_policy(task) without return types