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)[source]

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 0x9526810>
finalize_button_name = <django.utils.functional.__proxy__ object at 0x9526790>
name = <django.utils.functional.__proxy__ object at 0x9526750>
slug = 'lunch_job'
success_message = <django.utils.functional.__proxy__ object at 0x95267d0>
success_url = 'horizon:project:data_processing.cluster_templates:index'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.ClusterGeneralConfig(workflow)[source]

Bases: horizon.workflows.base.Step

action_class

alias of NewClusterConfigAction

contribute(data, context)[source]
contributes = ('hidden_configure_field',)
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobConfig(workflow)[source]

Bases: horizon.workflows.base.Step

action_class

alias of JobConfigAction

static clean_configs(configs)[source]
contribute(data, context)[source]
template_name = 'project/data_processing.jobs/config_template.html'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobConfigAction(request, *args, **kwargs)[source]

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 0x9524050>), ('job_configs', <django.forms.fields.CharField object at 0x9524110>), ('job_params', <django.forms.fields.CharField object at 0x9524190>), ('job_args_array', <django.forms.fields.CharField object at 0x9524210>), ('job_type', <django.forms.fields.CharField object at 0x9524290>), ('main_class', <django.forms.fields.CharField object at 0x9524310>), ('java_opts', <django.forms.fields.CharField object at 0x95243d0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x9524490>), ('streaming_reducer', <django.forms.fields.CharField object at 0x9524590>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x95246d0>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x9524810>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x9524990>)])
clean()[source]
clean_edp_configs(configs)[source]
declared_fields = OrderedDict([('property_name', <django.forms.fields.ChoiceField object at 0x9524050>), ('job_configs', <django.forms.fields.CharField object at 0x9524110>), ('job_params', <django.forms.fields.CharField object at 0x9524190>), ('job_args_array', <django.forms.fields.CharField object at 0x9524210>), ('job_type', <django.forms.fields.CharField object at 0x9524290>), ('main_class', <django.forms.fields.CharField object at 0x9524310>), ('java_opts', <django.forms.fields.CharField object at 0x95243d0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x9524490>), ('streaming_reducer', <django.forms.fields.CharField object at 0x9524590>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x95246d0>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x9524810>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x9524990>)])
help_text = ''
help_text_template = 'project/data_processing.jobs/_launch_job_configure_help.html'
media
name = <django.utils.functional.__proxy__ object at 0x9524a90>
permissions = ()
populate_property_name_choices(request, context)[source]
progress_message = <django.utils.functional.__proxy__ object at 0x9524cd0>
slug = u'jobconfigaction'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfig(workflow)[source]

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionExistingGeneralConfigAction

contribute(data, context)[source]
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfigAction(request, *args, **kwargs)[source]

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

base_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x961e910>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x961ead0>), ('cluster', <django.forms.fields.ChoiceField object at 0x961edd0>)])
declared_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x961e910>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x961ead0>), ('cluster', <django.forms.fields.ChoiceField object at 0x961edd0>)])
help_text = ''
help_text_template = 'project/data_processing.jobs/_launch_job_help.html'
media
name = <django.utils.functional.__proxy__ object at 0x961ee10>
permissions = ()
populate_cluster_choices(request, context)[source]
progress_message = <django.utils.functional.__proxy__ object at 0x961efd0>
slug = u'jobexecutionexistinggeneralconfigaction'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionGeneralConfig(workflow)[source]

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionGeneralConfigAction

contribute(data, context)[source]
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionGeneralConfigAction(request, *args, **kwargs)[source]

Bases: horizon.workflows.base.Action

base_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x961e910>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x961ead0>)])
declared_fields = OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x961e910>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x961ead0>)])
get_data_source_choices(request, context)[source]
help_text = ''
help_text_template = 'project/data_processing.jobs/_launch_job_help.html'
media
name = <django.utils.functional.__proxy__ object at 0x961eb90>
permissions = ()
populate_job_choices(request)[source]
populate_job_input_choices(request, context)[source]
populate_job_output_choices(request, context)[source]
progress_message = <django.utils.functional.__proxy__ object at 0x961ed10>
slug = u'jobexecutiongeneralconfigaction'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionInterfaceConfig(workflow)[source]

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionInterfaceConfigAction

contribute(data, context)[source]
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionInterfaceConfigAction(request, *args, **kwargs)[source]

Bases: horizon.workflows.base.Action

base_fields = OrderedDict()
clean()[source]
declared_fields = OrderedDict()
help_text = ''
help_text_template = None
media
name = <django.utils.functional.__proxy__ object at 0x9526110>
permissions = ()
progress_message = <django.utils.functional.__proxy__ object at 0x95262d0>
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)[source]

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 0x95263d0>
finalize_button_name = <django.utils.functional.__proxy__ object at 0x9526350>
handle(request, context)[source]
name = <django.utils.functional.__proxy__ object at 0x9526310>
slug = 'launch_job'
success_message = <django.utils.functional.__proxy__ object at 0x9526390>
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)[source]

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 0x95269d0>
finalize_button_name = <django.utils.functional.__proxy__ object at 0x9526950>
handle(request, context)[source]
name = <django.utils.functional.__proxy__ object at 0x95268d0>
slug = 'launch_job'
success_message = <django.utils.functional.__proxy__ object at 0x9526990>
success_url = 'horizon:project:data_processing.jobs:index'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.NewClusterConfigAction(request, *args, **kwargs)[source]

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

base_fields = OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x61c4910>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x61c4d10>), ('cluster_name', <django.forms.fields.CharField object at 0x61c4b10>), ('description', <django.forms.fields.CharField object at 0x61c4810>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x65adb50>), ('cluster_count', <django.forms.fields.IntegerField object at 0x65ad5d0>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x65ad850>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x65ad750>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x9524d90>)])
declared_fields = OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x61c4910>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x61c4d10>), ('cluster_name', <django.forms.fields.CharField object at 0x61c4b10>), ('description', <django.forms.fields.CharField object at 0x61c4810>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x65adb50>), ('cluster_count', <django.forms.fields.IntegerField object at 0x65ad5d0>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x65ad850>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x65ad750>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x9524d90>)])
help_text = ''
help_text_template = 'project/data_processing.clusters/_configure_general_help.html'
media
name = <django.utils.functional.__proxy__ object at 0x9524e50>
permissions = ()
progress_message = <django.utils.functional.__proxy__ object at 0x95260d0>
slug = u'newclusterconfigaction'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.SelectHadoopPlugin(workflow)[source]

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)[source]

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 0x71c87d0>)])
declared_fields = OrderedDict([('hidden_create_field', <django.forms.fields.CharField object at 0x71c87d0>)])
help_text = ''
help_text_template = 'project/data_processing.clusters/_create_general_help.html'
media
name = <django.utils.functional.__proxy__ object at 0x9526490>
permissions = ()
progress_message = <django.utils.functional.__proxy__ object at 0x9526710>
slug = u'selecthadooppluginaction'

Previous topic

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

Next topic

The openstack_dashboard.contrib.sahara.content.data_processing.nodegroup_templates Module

This Page