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.
code: def __init__(
      self,
      conn_id: str,
      run_id: int,
      end_time: float,
      poll_interval: float,
      account_id: int | None,
  ):
      super().__init__()
      self.run_id = run_id
      self.account_id = account_id
      self.conn_id = conn_id
      self.end_time = end_time
      self.poll_interval = 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 1 to create a new DbtCloudRunJobTrigger object from inherited base classes: BaseTrigger with example: obj = DbtCloudRunJobTrigger(conn_id, run_id, end_time, poll_interval, account_id)