(self, session, message, query, timeout, metrics=None, prepared_statement=None,
retry_policy=RetryPolicy(), row_factory=None, load_balancer=None, start_time=None,
speculative_execution_plan=None, continuous_paging_state=None, host=None)
| 4397 | _warned_timeout = False |
| 4398 | |
| 4399 | def __init__(self, session, message, query, timeout, metrics=None, prepared_statement=None, |
| 4400 | retry_policy=RetryPolicy(), row_factory=None, load_balancer=None, start_time=None, |
| 4401 | speculative_execution_plan=None, continuous_paging_state=None, host=None): |
| 4402 | self.session = session |
| 4403 | # TODO: normalize handling of retry policy and row factory |
| 4404 | self.row_factory = row_factory or session.row_factory |
| 4405 | self._load_balancer = load_balancer or session.cluster._default_load_balancing_policy |
| 4406 | self.message = message |
| 4407 | self.query = query |
| 4408 | self.timeout = timeout |
| 4409 | self._retry_policy = retry_policy |
| 4410 | self._metrics = metrics |
| 4411 | self.prepared_statement = prepared_statement |
| 4412 | self._callback_lock = Lock() |
| 4413 | self._start_time = start_time or time.time() |
| 4414 | self._host = host |
| 4415 | self._spec_execution_plan = speculative_execution_plan or self._spec_execution_plan |
| 4416 | self._make_query_plan() |
| 4417 | self._event = Event() |
| 4418 | self._errors = {} |
| 4419 | self._callbacks = [] |
| 4420 | self._errbacks = [] |
| 4421 | self.attempted_hosts = [] |
| 4422 | self._start_timer() |
| 4423 | self._continuous_paging_state = continuous_paging_state |
| 4424 | |
| 4425 | @property |
| 4426 | def _time_remaining(self): |
nothing calls this directly
no test coverage detected