class_docstr: Launch Airflow scheduler in the context.
class_docstr_tok: ["Launch","Airflow","scheduler","in","the","context","."]
code: def __init__(self):
      self._args = ["airflow", "scheduler"]
      self._sub_process = None
  
file_path: tfx/tfx/orchestration/airflow/test_utils.py
imports: import subprocess
  import time
  from typing import Tuple
  from absl import logging
  import docker
label_desc: Use image node_id 1 to create a new AirflowScheduler object  with example: obj = AirflowScheduler()