@staticmethod
def _get_operator_class_name(task_detail_type):
    """ Internal helper gets the name of the Airflow operator class. We maintain
      this in a map, so this method really returns the enum name, concatenated
      with the string "Operator".
    """
    task_type_to_operator_prefix_mapping = {'pydatalab.bq.execute': (
        'Execute',
        'google.datalab.contrib.bigquery.operators._bq_execute_operator'),
        'pydatalab.bq.extract': ('Extract',
        'google.datalab.contrib.bigquery.operators._bq_extract_operator'),
        'pydatalab.bq.load': ('Load',
        'google.datalab.contrib.bigquery.operators._bq_load_operator'),
        'Bash': ('Bash', 'airflow.operators.bash_operator')}
    operator_class_prefix, module = task_type_to_operator_prefix_mapping.get(
        task_detail_type, (None, __name__))
    format_string = '{0}Operator'
    operator_class_name = format_string.format(operator_class_prefix)
    if operator_class_prefix is None:
        return format_string.format(task_detail_type), module
    return operator_class_name, module
