The openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch Module

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.ChosePluginVersion(request=None, context_seed=None, entry_point=None, *args, **kwargs)

Bases: horizon.workflows.base.Workflow

default_steps = (<class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.SelectHadoopPlugin'>,)

failure_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479c90>

finalize_button_name = <django.utils.functional.__proxy__ object at 0x7fdfb4479b90>

name = <django.utils.functional.__proxy__ object at 0x7fdfb4479c10>

slug = 'lunch_job'

success_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479d10>

success_url = 'horizon:project:data_processing.cluster_templates:index'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.ClusterGeneralConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of NewClusterConfigAction

contribute(data, context)

contributes = ('hidden_configure_field',)

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of JobConfigAction

static clean_configs(configs)

contribute(data, context)

template_name = 'project/data_processing.jobs/config_template.html'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobConfigAction(request, *args, **kwargs)

Bases: horizon.workflows.base.Action

EDP_ADAPT_FOR_OOZIE = 'edp.java.adapt_for_oozie'

EDP_ADAPT_SPARK_SWIFT = 'edp.spark.adapt_for_swift'

EDP_HBASE_COMMON_LIB = 'edp.hbase_common_lib'

EDP_MAPPER = 'edp.streaming.mapper'

EDP_PREFIX = 'edp.'

EDP_REDUCER = 'edp.streaming.reducer'

JAVA_OPTS = 'edp.java.java_opts'

MAIN_CLASS = 'edp.java.main_class'

base_fields = OrderedDict([('property_name', <django.forms.fields.ChoiceField object at 0x7fdfb40af050>), ('job_configs', <django.forms.fields.CharField object at 0x7fdfb40af150>), ('job_params', <django.forms.fields.CharField object at 0x7fdfb40af350>), ('job_args_array', <django.forms.fields.CharField object at 0x7fdfb40af110>), ('job_type', <django.forms.fields.CharField object at 0x7fdfb40af390>), ('main_class', <django.forms.fields.CharField object at 0x7fdfb4791150>), ('java_opts', <django.forms.fields.CharField object at 0x7fdfb4791bd0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x7fdfb4791c50>), ('streaming_reducer', <django.forms.fields.CharField object at 0x7fdfb4791d50>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x7fdfb4791a90>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x7fdfb4791e10>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x7fdfb47913d0>)])

clean()

clean_edp_configs(configs)

declared_fields = OrderedDict([('property_name', <django.forms.fields.ChoiceField object at 0x7fdfb40af050>), ('job_configs', <django.forms.fields.CharField object at 0x7fdfb40af150>), ('job_params', <django.forms.fields.CharField object at 0x7fdfb40af350>), ('job_args_array', <django.forms.fields.CharField object at 0x7fdfb40af110>), ('job_type', <django.forms.fields.CharField object at 0x7fdfb40af390>), ('main_class', <django.forms.fields.CharField object at 0x7fdfb4791150>), ('java_opts', <django.forms.fields.CharField object at 0x7fdfb4791bd0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x7fdfb4791c50>), ('streaming_reducer', <django.forms.fields.CharField object at 0x7fdfb4791d50>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x7fdfb4791a90>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x7fdfb4791e10>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x7fdfb47913d0>)])

help_text = ''

help_text_template = 'project/data_processing.jobs/_launch_job_configure_help.html'

media

name = <django.utils.functional.__proxy__ object at 0x7fdfb4791250>

permissions = ()

populate_property_name_choices(request, context)

progress_message = <django.utils.functional.__proxy__ object at 0x7fdfb4791050>

slug = u'jobconfigaction'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionExistingGeneralConfigAction

contribute(data, context)

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfigAction(request, *args, **kwargs)

Bases: openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionGeneralConfigAction

base_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40afa90>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40af950>), ('cluster', <django.forms.fields.ChoiceField object at 0x7fdfb40af6d0>)])

declared_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40afa90>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40af950>), ('cluster', <django.forms.fields.ChoiceField object at 0x7fdfb40af6d0>)])

help_text = ''

help_text_template = 'project/data_processing.jobs/_launch_job_help.html'

media

name = <django.utils.functional.__proxy__ object at 0x7fdfb40afbd0>

permissions = ()

populate_cluster_choices(request, context)

progress_message = <django.utils.functional.__proxy__ object at 0x7fdfb40af090>

slug = u'jobexecutionexistinggeneralconfigaction'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionGeneralConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionGeneralConfigAction

contribute(data, context)

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionGeneralConfigAction(request, *args, **kwargs)

Bases: horizon.workflows.base.Action

base_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40afa90>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40af950>)])

declared_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40afa90>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb40af950>)])

get_data_source_choices(request, context)

help_text = ''

help_text_template = 'project/data_processing.jobs/_launch_job_help.html'

media

name = <django.utils.functional.__proxy__ object at 0x7fdfb40af990>

permissions = ()

populate_job_choices(request)

populate_job_input_choices(request, context)

populate_job_output_choices(request, context)

progress_message = <django.utils.functional.__proxy__ object at 0x7fdfb40afa10>

slug = u'jobexecutiongeneralconfigaction'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionInterfaceConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionInterfaceConfigAction

contribute(data, context)

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionInterfaceConfigAction(request, *args, **kwargs)

Bases: horizon.workflows.base.Action

base_fields = OrderedDict()

clean()

declared_fields = OrderedDict()

help_text = ''

help_text_template = None

media

name = <django.utils.functional.__proxy__ object at 0x7fdfb4479810>

permissions = ()

progress_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479750>

slug = u'jobexecutioninterfaceconfigaction'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.LaunchJob(request=None, context_seed=None, entry_point=None, *args, **kwargs)

Bases: horizon.workflows.base.Workflow

default_steps = (<class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfig'>, <class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobConfig'>, <class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionInterfaceConfig'>)

failure_message = <django.utils.functional.__proxy__ object at 0x7fdfb44795d0>

finalize_button_name = <django.utils.functional.__proxy__ object at 0x7fdfb4479650>

handle(request, context)

name = <django.utils.functional.__proxy__ object at 0x7fdfb4479210>

slug = 'launch_job'

success_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479690>

success_url = 'horizon:project:data_processing.job_executions:index'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.LaunchJobNewCluster(request=None, context_seed=None, entry_point=None, *args, **kwargs)

Bases: horizon.workflows.base.Workflow

default_steps = (<class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.ClusterGeneralConfig'>, <class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionGeneralConfig'>, <class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobConfig'>, <class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionInterfaceConfig'>)

failure_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479a90>

finalize_button_name = <django.utils.functional.__proxy__ object at 0x7fdfb4479d90>

handle(request, context)

name = <django.utils.functional.__proxy__ object at 0x7fdfb4479dd0>

slug = 'launch_job'

success_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479e10>

success_url = 'horizon:project:data_processing.jobs:index'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.NewClusterConfigAction(request, *args, **kwargs)

Bases: openstack_dashboard.contrib.sahara.content.data_processing.clusters.workflows.create.GeneralConfigAction

base_fields = OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x7fdfb6c83d50>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x7fdfb6c83890>), ('cluster_name', <django.forms.fields.CharField object at 0x7fdfb6c83110>), ('description', <django.forms.fields.CharField object at 0x7fdfb4c5b210>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb572dbd0>), ('cluster_count', <django.forms.fields.IntegerField object at 0x7fdfb5c33110>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb5c33f90>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb5c33e90>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x7fdfb5d98c10>)])

declared_fields = OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x7fdfb6c83d50>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x7fdfb6c83890>), ('cluster_name', <django.forms.fields.CharField object at 0x7fdfb6c83110>), ('description', <django.forms.fields.CharField object at 0x7fdfb4c5b210>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb572dbd0>), ('cluster_count', <django.forms.fields.IntegerField object at 0x7fdfb5c33110>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb5c33f90>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x7fdfb5c33e90>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x7fdfb5d98c10>)])

help_text = ''

help_text_template = 'project/data_processing.clusters/_configure_general_help.html'

media

name = <django.utils.functional.__proxy__ object at 0x7fdfb5d98d90>

permissions = ()

progress_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479fd0>

slug = u'newclusterconfigaction'

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.SelectHadoopPlugin(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of SelectHadoopPluginAction

class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.SelectHadoopPluginAction(request, *args, **kwargs)

Bases: openstack_dashboard.contrib.sahara.content.data_processing.cluster_templates.workflows.create.SelectPluginAction

base_fields = OrderedDict([('hidden_create_field', <django.forms.fields.CharField object at 0x7fdfb55fac90>)])

declared_fields = OrderedDict([('hidden_create_field', <django.forms.fields.CharField object at 0x7fdfb55fac90>)])

help_text = ''

help_text_template = 'project/data_processing.clusters/_create_general_help.html'

media

name = <django.utils.functional.__proxy__ object at 0x7fdfb4479610>

permissions = ()

progress_message = <django.utils.functional.__proxy__ object at 0x7fdfb4479350>

slug = u'selecthadooppluginaction'