code: def test_init_with_timeout_and_max_ingestion_time():
      operator = DruidOperator(
          task_id="spark_submit_job",
          json_index_file=JSON_INDEX_STR,
          timeout=60,
          max_ingestion_time=180,
          params={
              "index_type": "index_hadoop",
              "datasource": "datasource_prd",
          },
      )
  
      expected_values = {
          "task_id": "spark_submit_job",
          "timeout": 60,
          "max_ingestion_time": 180,
      }
      assert expected_values["task_id"] == operator.task_id
      assert expected_values["timeout"] == operator.timeout
      assert (
          expected_values["max_ingestion_time"]
          == operator.max_ingestion_time
      )
  
file_path: airflow/tests/providers/apache/druid/operators/test_druid.py
imports: from __future__ import annotations
  import json
  from unittest.mock import MagicMock, patch
  import pytest
  from airflow.providers.apache.druid.hooks.druid import IngestionType
  from airflow.providers.apache.druid.operators.druid import DruidOperator
  from airflow.utils import timezone
  from airflow.utils.types import DagRunType
label_desc: Use image node_id 3 for calling a global function with example usage: test_init_with_timeout_and_max_ingestion_time() without return types