code: def test_maybe_refresh_metadata_ttl(mocker, client):
      client.cluster.ttl.return_value = 1234
      mocker.patch.object(
          KafkaClient, "in_flight_request_count", return_value=1
      )
  
      client.poll(timeout_ms=12345678)
      client._poll.assert_called_with(1.234)
  
imports: from __future__ import absolute_import, division
  import socket
  import time
  import pytest
  from kafka.client_async import KafkaClient, IdleConnectionManager
  from kafka.cluster import ClusterMetadata
  from kafka.conn import ConnectionStates
  import kafka.errors
  from kafka.future import Future
  from kafka.protocol.metadata import MetadataRequest
  from kafka.protocol.produce import ProduceRequest
  from kafka.structs import BrokerMetadata
label_desc: Use image node_id 17 for calling a global function with example usage: test_maybe_refresh_metadata_ttl(mocker, client) without return types