code: def test_init_default_timeout():
      operator = DruidOperator(
          task_id="spark_submit_job",
          json_index_file=JSON_INDEX_STR,
          params={
              "index_type": "index_hadoop",
              "datasource": "datasource_prd",
          },
      )
      expected_default_timeout = 1
      assert expected_default_timeout == operator.timeout
  
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 4 for calling a global function with example usage: test_init_default_timeout() without return types