class_docstr: MetaflowTask prepares a Flow instance for execution of a single step.
class_docstr_tok: ["MetaflowTask","prepares","a","Flow","instance","for","execution","of","a","single","step","."]
code: def __init__(
      self,
      flow,
      flow_datastore,
      metadata,
      environment,
      console_logger,
      event_logger,
      monitor,
      ubf_context,
  ):
      self.flow = flow
      self.flow_datastore = flow_datastore
      self.metadata = metadata
      self.environment = environment
      self.console_logger = console_logger
      self.event_logger = event_logger
      self.monitor = monitor
      self.ubf_context = ubf_context
  
imports: from __future__ import print_function
  from io import BytesIO
  import math
  import sys
  import os
  import time
  from types import MethodType, FunctionType
  from metaflow.datastore.exceptions import DataException
  from .metaflow_config import MAX_ATTEMPTS
  from .metadata import MetaDatum
  from .mflog import TASK_LOG_SOURCE
  from .datastore import Inputs, TaskDataStoreSet
  from .exception import MetaflowInternalError, MetaflowDataMissing, MetaflowExceptionWrapper
  from .unbounded_foreach import UBF_CONTROL
  from .util import all_equal, get_username, resolve_identity, unicode_type
  from .current import current
  from metaflow.tracing import get_trace_id
  from collections import namedtuple
label_desc: Use image node_id 1 to create a new MetaflowTask object from inherited base classes: object with example: obj = MetaflowTask(flow, flow_datastore, metadata, environment, console_logger, event_logger, monitor, ubf_context)