code: def __init__(
      self,
      name,
      operator_type="kubernetes",
      flow_name=None,
      is_mapper_node=False,
      flow_contains_foreach=False,
  ):
      self.name = name
      self._is_mapper_node = is_mapper_node
      self._operator_args = None
      self._operator_type = operator_type
      self._flow_name = flow_name
      self._flow_contains_foreach = flow_contains_foreach
  
imports: import hashlib
  import json
  import sys
  import platform
  from collections import defaultdict
  from datetime import datetime, timedelta
label_desc: Use image node_id 1 to create a new AirflowTask object from inherited base classes: object with example: obj = AirflowTask(name, operator_type, flow_name, is_mapper_node, flow_contains_foreach)