The openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch Module

class openstack_dashboard.dashboards.project.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.dashboards.project.data_processing.jobs.workflows.launch.SelectHadoopPlugin'>,)

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

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

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

slug = 'lunch_job'

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

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

class openstack_dashboard.dashboards.project.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.dashboards.project.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.dashboards.project.data_processing.jobs.workflows.launch.JobConfigAction(request, *args, **kwargs)

Bases: horizon.workflows.base.Action

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 = {'property_name': <django.forms.fields.ChoiceField object at 0x5afc510>, 'job_configs': <django.forms.fields.CharField object at 0x5afc5d0>, 'job_params': <django.forms.fields.CharField object at 0x5afc650>, 'job_args_array': <django.forms.fields.CharField object at 0x5afc6d0>, 'job_type': <django.forms.fields.CharField object at 0x5afc750>, 'main_class': <django.forms.fields.CharField object at 0x5afc7d0>, 'java_opts': <django.forms.fields.CharField object at 0x5afc8d0>, 'streaming_mapper': <django.forms.fields.CharField object at 0x5afc9d0>, 'streaming_reducer': <django.forms.fields.CharField object at 0x5afcad0>}

clean()

clean_edp_configs(configs)

help_text = ''

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

media

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

permissions = ()

populate_property_name_choices(request, context)

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

slug = u'jobconfigaction'

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionExistingGeneralConfigAction

contribute(data, context)

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfigAction(request, *args, **kwargs)

Bases: openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionGeneralConfigAction

base_fields = {'job_input': <horizon.forms.fields.DynamicChoiceField object at 0x5afc050>, 'job_output': <horizon.forms.fields.DynamicChoiceField object at 0x5afc110>, 'cluster': <django.forms.fields.ChoiceField object at 0x5afc310>}

help_text = ''

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

media

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

permissions = ()

populate_cluster_choices(request, context)

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

slug = u'jobexecutionexistinggeneralconfigaction'

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionGeneralConfig(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of JobExecutionGeneralConfigAction

contribute(data, context)

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionGeneralConfigAction(request, *args, **kwargs)

Bases: horizon.workflows.base.Action

base_fields = {'job_input': <horizon.forms.fields.DynamicChoiceField object at 0x5afc050>, 'job_output': <horizon.forms.fields.DynamicChoiceField object at 0x5afc110>}

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 0x5afc190>

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 0x5afc250>

slug = u'jobexecutiongeneralconfigaction'

class openstack_dashboard.dashboards.project.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.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionExistingGeneralConfig'>, <class 'openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobConfig'>)

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

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

handle(request, context)

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

slug = 'launch_job'

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

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

class openstack_dashboard.dashboards.project.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.dashboards.project.data_processing.jobs.workflows.launch.ClusterGeneralConfig'>, <class 'openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobExecutionGeneralConfig'>, <class 'openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.JobConfig'>)

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

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

handle(request, context)

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

slug = 'launch_job'

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

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

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.NewClusterConfigAction(request, *args, **kwargs)

Bases: openstack_dashboard.dashboards.project.data_processing.clusters.workflows.create.GeneralConfigAction

base_fields = {'hidden_configure_field': <django.forms.fields.CharField object at 0x5b01650>, 'hidden_to_delete_field': <django.forms.fields.CharField object at 0x5b01790>, 'cluster_name': <django.forms.fields.CharField object at 0x5b01810>, 'description': <django.forms.fields.CharField object at 0x5b01910>, 'cluster_template': <django.forms.fields.ChoiceField object at 0x5b01a10>, 'image': <django.forms.fields.ChoiceField object at 0x5b01b10>, 'keypair': <horizon.forms.fields.DynamicChoiceField object at 0x5b01c50>, 'persist_cluster': <django.forms.fields.BooleanField object at 0x5afcd90>}

help_text = ''

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

media

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

permissions = ()

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

slug = u'newclusterconfigaction'

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.SelectHadoopPlugin(workflow)

Bases: horizon.workflows.base.Step

action_class

alias of SelectHadoopPluginAction

class openstack_dashboard.dashboards.project.data_processing.jobs.workflows.launch.SelectHadoopPluginAction(request, *args, **kwargs)

Bases: openstack_dashboard.dashboards.project.data_processing.cluster_templates.workflows.create.SelectPluginAction

base_fields = {'hidden_create_field': <django.forms.fields.CharField object at 0x5af5250>}

help_text = ''

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

media

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

permissions = ()

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

slug = u'selecthadooppluginaction'