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>
-
finalize_button_name
= <django.utils.functional.__proxy__ object>
-
name
= <django.utils.functional.__proxy__ object>
-
slug
= 'lunch_job'
-
success_message
= <django.utils.functional.__proxy__ object>
-
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 0x2b4c5105ed50>), ('job_configs', <django.forms.fields.CharField object at 0x2b4c4fd22950>), ('job_params', <django.forms.fields.CharField object at 0x2b4c4fd226d0>), ('job_args_array', <django.forms.fields.CharField object at 0x2b4c4fd225d0>), ('job_type', <django.forms.fields.CharField object at 0x2b4c4fef3e90>), ('main_class', <django.forms.fields.CharField object at 0x2b4c4fef3b90>), ('java_opts', <django.forms.fields.CharField object at 0x2b4c502319d0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x2b4c50231fd0>), ('streaming_reducer', <django.forms.fields.CharField object at 0x2b4c5047c9d0>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x2b4c5047ce10>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x2b4c5047c4d0>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x2b4c5047c690>)])
-
clean
()[source]
-
clean_edp_configs
(configs)[source]
-
declared_fields
= OrderedDict([('property_name', <django.forms.fields.ChoiceField object at 0x2b4c5105ed50>), ('job_configs', <django.forms.fields.CharField object at 0x2b4c4fd22950>), ('job_params', <django.forms.fields.CharField object at 0x2b4c4fd226d0>), ('job_args_array', <django.forms.fields.CharField object at 0x2b4c4fd225d0>), ('job_type', <django.forms.fields.CharField object at 0x2b4c4fef3e90>), ('main_class', <django.forms.fields.CharField object at 0x2b4c4fef3b90>), ('java_opts', <django.forms.fields.CharField object at 0x2b4c502319d0>), ('streaming_mapper', <django.forms.fields.CharField object at 0x2b4c50231fd0>), ('streaming_reducer', <django.forms.fields.CharField object at 0x2b4c5047c9d0>), ('hbase_common_lib', <django.forms.fields.BooleanField object at 0x2b4c5047ce10>), ('adapt_oozie', <django.forms.fields.BooleanField object at 0x2b4c5047c4d0>), ('adapt_spark_swift', <django.forms.fields.BooleanField object at 0x2b4c5047c690>)])
-
help_text
= ''
-
help_text_template
= 'project/data_processing.jobs/_launch_job_configure_help.html'
-
media
-
name
= <django.utils.functional.__proxy__ object>
-
permissions
= ()
-
populate_property_name_choices
(request, context)[source]
-
progress_message
= <django.utils.functional.__proxy__ object>
-
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 0x2b4c4eeba650>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c4fa9ae50>), ('cluster', <django.forms.fields.ChoiceField object at 0x2b4c4fc71d50>), ('is_public', <django.forms.fields.BooleanField object at 0x2b4c4fc710d0>), ('is_protected', <django.forms.fields.BooleanField object at 0x2b4c5105ef50>)])
-
declared_fields
= OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c4eeba650>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c4fa9ae50>), ('cluster', <django.forms.fields.ChoiceField object at 0x2b4c4fc71d50>), ('is_public', <django.forms.fields.BooleanField object at 0x2b4c4fc710d0>), ('is_protected', <django.forms.fields.BooleanField object at 0x2b4c5105ef50>)])
-
help_text
= ''
-
help_text_template
= 'project/data_processing.jobs/_launch_job_help.html'
-
media
-
name
= <django.utils.functional.__proxy__ object>
-
permissions
= ()
-
populate_cluster_choices
(request, context)[source]
-
progress_message
= <django.utils.functional.__proxy__ object>
-
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 0x2b4c4eeba650>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c4fa9ae50>)])
-
declared_fields
= OrderedDict([('job_input', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c4eeba650>), ('job_output', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c4fa9ae50>)])
-
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>
-
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>
-
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>
-
permissions
= ()
-
progress_message
= <django.utils.functional.__proxy__ object>
-
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>
-
finalize_button_name
= <django.utils.functional.__proxy__ object>
-
handle
(request, context)[source]
-
name
= <django.utils.functional.__proxy__ object>
-
slug
= 'launch_job'
-
success_message
= <django.utils.functional.__proxy__ object>
-
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>
-
finalize_button_name
= <django.utils.functional.__proxy__ object>
-
handle
(request, context)[source]
-
name
= <django.utils.functional.__proxy__ object>
-
slug
= 'launch_job'
-
success_message
= <django.utils.functional.__proxy__ object>
-
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 0x2b4c509970d0>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x2b4c50997650>), ('cluster_name', <django.forms.fields.CharField object at 0x2b4c50997410>), ('description', <django.forms.fields.CharField object at 0x2b4c50997550>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c50997dd0>), ('cluster_count', <django.forms.fields.IntegerField object at 0x2b4c5028f6d0>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c5028f410>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c5028f510>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x2b4c5047c190>)])
-
declared_fields
= OrderedDict([('hidden_configure_field', <django.forms.fields.CharField object at 0x2b4c509970d0>), ('hidden_to_delete_field', <django.forms.fields.CharField object at 0x2b4c50997650>), ('cluster_name', <django.forms.fields.CharField object at 0x2b4c50997410>), ('description', <django.forms.fields.CharField object at 0x2b4c50997550>), ('cluster_template', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c50997dd0>), ('cluster_count', <django.forms.fields.IntegerField object at 0x2b4c5028f6d0>), ('image', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c5028f410>), ('keypair', <horizon.forms.fields.DynamicChoiceField object at 0x2b4c5028f510>), ('persist_cluster', <django.forms.fields.BooleanField object at 0x2b4c5047c190>)])
-
help_text
= ''
-
help_text_template
= 'project/data_processing.clusters/_configure_general_help.html'
-
media
-
name
= <django.utils.functional.__proxy__ object>
-
permissions
= ()
-
progress_message
= <django.utils.functional.__proxy__ object>
-
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 0x2b4c500eed50>)])
-
declared_fields
= OrderedDict([('hidden_create_field', <django.forms.fields.CharField object at 0x2b4c500eed50>)])
-
help_text
= ''
-
help_text_template
= 'project/data_processing.clusters/_create_general_help.html'
-
media
-
name
= <django.utils.functional.__proxy__ object>
-
permissions
= ()
-
progress_message
= <django.utils.functional.__proxy__ object>
-
slug
= u'selecthadooppluginaction'
-