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

ChosePluginVersion.default_steps = (<class 'openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.SelectHadoopPlugin'>,)
ChosePluginVersion.failure_message = <django.utils.functional.__proxy__ object at 0x9970c10>
ChosePluginVersion.finalize_button_name = <django.utils.functional.__proxy__ object at 0x9970b90>
ChosePluginVersion.name = <django.utils.functional.__proxy__ object at 0x9970b50>
ChosePluginVersion.slug = 'lunch_job'
ChosePluginVersion.success_message = <django.utils.functional.__proxy__ object at 0x9970bd0>
ChosePluginVersion.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

ClusterGeneralConfig.action_class

alias of NewClusterConfigAction

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

Bases: horizon.workflows.base.Step

JobConfig.action_class

alias of JobConfigAction

static JobConfig.clean_configs(configs)[source]
JobConfig.contribute(data, context)[source]
JobConfig.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

JobConfigAction.EDP_ADAPT_FOR_OOZIE = 'edp.java.adapt_for_oozie'
JobConfigAction.EDP_ADAPT_SPARK_SWIFT = 'edp.spark.adapt_for_swift'
JobConfigAction.EDP_HBASE_COMMON_LIB = 'edp.hbase_common_lib'
JobConfigAction.EDP_MAPPER = 'edp.streaming.mapper'
JobConfigAction.EDP_PREFIX = 'edp.'
JobConfigAction.EDP_REDUCER = 'edp.streaming.reducer'
JobConfigAction.JAVA_OPTS = 'edp.java.java_opts'
JobConfigAction.MAIN_CLASS = 'edp.java.main_class'
JobConfigAction.base_fields = OrderedDict([('property_name', <django.forms.fields.ChoiceField object at 0x996d450>), ('job_configs', <django.forms.fields.CharField object at 0x996d510>), ('job_params', <django.forms.fields.CharField object at 0x996d590>), ('job_args_array', <django.forms.fields.CharField object at 0x996d610>), ('job_type', <django.forms.fields.CharField object at 0x996d690>), ('main_class', <django.forms.fields.CharField object at 0x996d710>), ('java_opts', <django.forms.fields.CharField object at 0x996d7d0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x996d890>), ('streaming_reducer', <django.forms.fields.CharField object at 0x996d990>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x996dad0>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x996dc10>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x996dd90>)])
JobConfigAction.clean()[source]
JobConfigAction.clean_edp_configs(configs)[source]
JobConfigAction.declared_fields = OrderedDict([('property_name', <django.forms.fields.ChoiceField object at 0x996d450>), ('job_configs', <django.forms.fields.CharField object at 0x996d510>), ('job_params', <django.forms.fields.CharField object at 0x996d590>), ('job_args_array', <django.forms.fields.CharField object at 0x996d610>), ('job_type', <django.forms.fields.CharField object at 0x996d690>), ('main_class', <django.forms.fields.CharField object at 0x996d710>), ('java_opts', <django.forms.fields.CharField object at 0x996d7d0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x996d890>), ('streaming_reducer', <django.forms.fields.CharField object at 0x996d990>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x996dad0>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x996dc10>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x996dd90>)])
JobConfigAction.help_text = ''
JobConfigAction.help_text_template = 'project/data_processing.jobs/_launch_job_configure_help.html'
JobConfigAction.media
JobConfigAction.name = <django.utils.functional.__proxy__ object at 0x996de90>
JobConfigAction.permissions = ()
JobConfigAction.populate_property_name_choices(request, context)[source]
JobConfigAction.progress_message = <django.utils.functional.__proxy__ object at 0x9970110>
JobConfigAction.slug = u'jobconfigaction'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfig(workflow)[source]

Bases: horizon.workflows.base.Step

JobExecutionExistingGeneralConfig.action_class

alias of JobExecutionExistingGeneralConfigAction

JobExecutionExistingGeneralConfig.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

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

Bases: horizon.workflows.base.Step

JobExecutionGeneralConfig.action_class

alias of JobExecutionGeneralConfigAction

JobExecutionGeneralConfig.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

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

Bases: horizon.workflows.base.Step

JobExecutionInterfaceConfig.action_class

alias of JobExecutionInterfaceConfigAction

JobExecutionInterfaceConfig.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

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

LaunchJob.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'>)
LaunchJob.failure_message = <django.utils.functional.__proxy__ object at 0x99707d0>
LaunchJob.finalize_button_name = <django.utils.functional.__proxy__ object at 0x9970750>
LaunchJob.handle(request, context)[source]
LaunchJob.name = <django.utils.functional.__proxy__ object at 0x9970710>
LaunchJob.slug = 'launch_job'
LaunchJob.success_message = <django.utils.functional.__proxy__ object at 0x9970790>
LaunchJob.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

LaunchJobNewCluster.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'>)
LaunchJobNewCluster.failure_message = <django.utils.functional.__proxy__ object at 0x9970dd0>
LaunchJobNewCluster.finalize_button_name = <django.utils.functional.__proxy__ object at 0x9970d50>
LaunchJobNewCluster.handle(request, context)[source]
LaunchJobNewCluster.name = <django.utils.functional.__proxy__ object at 0x9970cd0>
LaunchJobNewCluster.slug = 'launch_job'
LaunchJobNewCluster.success_message = <django.utils.functional.__proxy__ object at 0x9970d90>
LaunchJobNewCluster.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

NewClusterConfigAction.base_fields = OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x941e210>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x941e510>), ('cluster_name', <django.forms.fields.CharField object at 0x941e8d0>), ('description', <django.forms.fields.CharField object at 0x941e150>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x941ec50>), ('cluster_count', <django.forms.fields.IntegerField object at 0x941f910>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x941f490>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x941fa90>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x99701d0>)])
NewClusterConfigAction.declared_fields = OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x941e210>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x941e510>), ('cluster_name', <django.forms.fields.CharField object at 0x941e8d0>), ('description', <django.forms.fields.CharField object at 0x941e150>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x941ec50>), ('cluster_count', <django.forms.fields.IntegerField object at 0x941f910>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x941f490>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x941fa90>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x99701d0>)])
NewClusterConfigAction.help_text = ''
NewClusterConfigAction.help_text_template = 'project/data_processing.clusters/_configure_general_help.html'
NewClusterConfigAction.media
NewClusterConfigAction.name = <django.utils.functional.__proxy__ object at 0x9970290>
NewClusterConfigAction.permissions = ()
NewClusterConfigAction.progress_message = <django.utils.functional.__proxy__ object at 0x99704d0>
NewClusterConfigAction.slug = u'newclusterconfigaction'
class openstack_dashboard.contrib.sahara.content.data_processing.jobs.workflows.launch.SelectHadoopPlugin(workflow)[source]

Bases: horizon.workflows.base.Step

SelectHadoopPlugin.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

SelectHadoopPluginAction.base_fields = OrderedDict([('hidden_create_field', <django.forms.fields.CharField object at 0x87767d0>)])
SelectHadoopPluginAction.declared_fields = OrderedDict([('hidden_create_field', <django.forms.fields.CharField object at 0x87767d0>)])
SelectHadoopPluginAction.help_text = ''
SelectHadoopPluginAction.help_text_template = 'project/data_processing.clusters/_create_general_help.html'
SelectHadoopPluginAction.media
SelectHadoopPluginAction.name = <django.utils.functional.__proxy__ object at 0x9970890>
SelectHadoopPluginAction.permissions = ()
SelectHadoopPluginAction.progress_message = <django.utils.functional.__proxy__ object at 0x9970b10>
SelectHadoopPluginAction.slug = u'selecthadooppluginaction'

Previous topic

The openstack_dashboard.contrib.sahara.content.data_processing.jobs.tables Module

Next topic

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

This Page