Source code for openstack_dashboard.dashboards.project.data_processing.job_executions.tables

# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
# implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import logging

from django.core.urlresolvers import reverse
from django.utils import http
from django.utils.translation import ugettext_lazy as _
from django.utils.translation import ungettext_lazy

from horizon import tables

from openstack_dashboard.api import sahara as saharaclient
from openstack_dashboard.dashboards.project.data_processing. \
    jobs import tables as j_t

LOG = logging.getLogger(__name__)


[docs]class DeleteJobExecution(tables.BatchAction): @staticmethod
[docs] def action_present(count): return ungettext_lazy( u"Delete Job execution", u"Delete Job executions", count )
@staticmethod
[docs] def action_past(count): return ungettext_lazy( u"Deleted Job execution", u"Deleted Job executions", count )
name = "delete" classes = ('btn-danger', 'btn-terminate')
[docs] def action(self, request, obj_id): saharaclient.job_execution_delete(request, obj_id)
[docs]class ReLaunchJobExistingCluster(j_t.ChoosePlugin): @staticmethod
[docs] def action_present(count): return ungettext_lazy( u"Launch Job", u"Launch Jobs", count )
@staticmethod
[docs] def action_past(count): return ungettext_lazy( u"Launched Job", u"Launched Jobs", count )
name = "relaunch-job-existing" verbose_name = _("Relaunch On Existing Cluster") url = "horizon:project:data_processing.jobs:launch-job" classes = ('ajax-modal', 'btn-launch')
[docs]class ReLaunchJobNewCluster(ReLaunchJobExistingCluster): @staticmethod
[docs] def action_present(count): return ungettext_lazy( u"Launch Job", u"Launch Jobs", count )
@staticmethod
[docs] def action_past(count): return ungettext_lazy( u"Launched Job", u"Launched Jobs", count )
name = "relaunch-job-new" verbose_name = _("Relaunch On New Cluster") url = "horizon:project:data_processing.jobs:choose-plugin" classes = ('ajax-modal', 'btn-launch')
[docs]class UpdateRow(tables.Row): ajax = True
[docs] def get_data(self, request, job_execution_id): job_execution = saharaclient.job_execution_get(request, job_execution_id) return job_execution
[docs]class JobExecutionsTable(tables.DataTable):
[docs] class StatusColumn(tables.Column):
[docs] def get_raw_data(self, datum): return datum.info['status']
STATUS_CHOICES = ( ("DONEWITHERROR", False), ("FAILED", False), ("KILLED", False), ("SUCCEEDED", True), ) name = tables.Column("id", verbose_name=_("ID"), display_choices=(("id", "ID"), ("name", "Name")), link=("horizon:project:data_processing.job_executions:details")) job_name = tables.Column( "job_name", verbose_name=_("Job"), link=get_job_link) cluster_name = tables.Column( "cluster_name", verbose_name=_("Cluster"), link=get_cluster_link) status = StatusColumn("info", status=True, status_choices=STATUS_CHOICES, verbose_name=_("Status"))
[docs] def get_object_display(self, datum): return datum.id
[docs] class Meta: name = "job_executions" row_class = UpdateRow status_columns = ["status"] verbose_name = _("Job Executions") table_actions = [DeleteJobExecution] row_actions = [DeleteJobExecution, ReLaunchJobExistingCluster, ReLaunchJobNewCluster]