class_docstr: Trigger to make an HTTP call to dbt and get the status for the job.
  
  This is done with run id in polling interval of time.
  
  :param conn_id: The connection identifier for connecting to Dbt.
  :param run_id: The ID of a dbt Cloud job.
  :param end_time: Time in seconds to wait for a job run to reach a terminal status. Defaults to 7 days.
  :param account_id: The ID of a dbt Cloud account.
  :param poll_interval:  polling period in seconds to check for the status.
docstr: Serialize DbtCloudRunJobTrigger arguments and classpath.
code: def serialize(self) -> tuple[str, dict[str, Any]]:
      """Serialize DbtCloudRunJobTrigger arguments and classpath."""
      return (
          "airflow.providers.dbt.cloud.triggers.dbt.DbtCloudRunJobTrigger",
          {
              "run_id": self.run_id,
              "account_id": self.account_id,
              "conn_id": self.conn_id,
              "end_time": self.end_time,
              "poll_interval": self.poll_interval,
          },
      )
  
file_path: airflow/airflow/providers/dbt/cloud/triggers/dbt.py
imports: from __future__ import annotations
  import asyncio
  import time
  from typing import Any, AsyncIterator
  from airflow.providers.dbt.cloud.hooks.dbt import DbtCloudHook, DbtCloudJobRunStatus
  from airflow.triggers.base import BaseTrigger, TriggerEvent
label_desc: Use image node_id 2 for calling the DbtCloudRunJobTrigger obj's underlying member method code with example usage: obj.serialize() and returns: str,  dict