class_docstr: LocalWorkerBase implementation to run airflow commands.
  
  Executes the given command and puts the result into a result queue when done, terminating execution.
  
  :param result_queue: the queue to store result state
class_docstr_tok: ["LocalWorkerBase","implementation","to","run","airflow","commands",".","Executes","the","given","command","and","puts","the","result","into","a","result","queue","when","done",",","terminating","execution",".",":","param","result_queue",":","the","queue","to","store","result","state"]
code: def __init__(self, result_queue: Queue[TaskInstanceStateType]):
      super().__init__(target=self.do_work)
      self.daemon: bool = True
      self.result_queue: Queue[TaskInstanceStateType] = result_queue
  
imports: from __future__ import annotations
  import contextlib
  import logging
  import os
  import subprocess
  from abc import abstractmethod
  from multiprocessing import Manager, Process
  from queue import Empty
  from typing import TYPE_CHECKING, Any, Optional, Tuple
  from setproctitle import getproctitle, setproctitle
  from airflow import settings
  from airflow.exceptions import AirflowException
  from airflow.executors.base_executor import PARALLELISM, BaseExecutor
  from airflow.utils.log.logging_mixin import LoggingMixin
  from airflow.utils.state import TaskInstanceState
label_desc: Use image node_id 1 to create a new LocalWorkerBase object from inherited base classes: Process, LoggingMixin with example: obj = LocalWorkerBase(result_queue)