class_docstr: Hook for Airbyte API.
  
  :param airbyte_conn_id: Optional. The name of the Airflow connection to get
      connection information for Airbyte. Defaults to "airbyte_default".
  :param api_version: Optional. Airbyte API version. Defaults to "v1".
class_docstr_tok: ["Hook","for","Airbyte","API",".",":","param","airbyte_conn_id",":","Optional",".","The","name","of","the","Airflow","connection","to","get","connection","information","for","Airbyte",".","Defaults","to","``","airbyte_default","''",".",":","param","api_version",":","Optional",".","Airbyte","API","version",".","Defaults","to","``","v1","''","."]
docstr: Cancel the job when task is cancelled.
  
  :param job_id: Required. Id of the Airbyte job
docstr_tok: ["Cancel","the","job","when","task","is","cancelled",".",":","param","job_id",":","Required",".","Id","of","the","Airbyte","job"]
code: def cancel_job(self, job_id: int) -> Any:
      """
      Cancel the job when task is cancelled.
  
      :param job_id: Required. Id of the Airbyte job
      """
      return self.run(
          endpoint=f"api/{self.api_version}/jobs/cancel",
          json={"id": job_id},
          headers={"accept": "application/json"},
      )
  
file_path: airflow/airflow/providers/airbyte/hooks/airbyte.py
imports: from __future__ import annotations
  import time
  from typing import Any
  from airflow.exceptions import AirflowException
  from airflow.providers.http.hooks.http import HttpHook
label_desc: Use image node_id 5 for calling the AirbyteHook obj's underlying member method code with example usage: obj.cancel_job(job_id) and returns: self