Pārlūkot izejas kodu

HUE-3162 [oozie] Change Bundle submission start and end date to server TZ

Note: This fix is needed because of HUE-1910
krish 10 gadi atpakaļ
vecāks
revīzija
d11af65
1 mainītis faili ar 6 papildinājumiem un 0 dzēšanām
  1. 6 0
      apps/oozie/src/oozie/views/editor2.py

+ 6 - 0
apps/oozie/src/oozie/views/editor2.py

@@ -39,6 +39,7 @@ from oozie.forms import ParameterForm
 from oozie.models import Workflow as OldWorklow, Coordinator as OldCoordinator, Bundle as OldBundle, Job
 from oozie.models import Workflow as OldWorklow, Coordinator as OldCoordinator, Bundle as OldBundle, Job
 from oozie.models2 import Node, Workflow, Coordinator, Bundle, NODES, WORKFLOW_NODE_PROPERTIES, import_workflow_from_hue_3_7,\
 from oozie.models2 import Node, Workflow, Coordinator, Bundle, NODES, WORKFLOW_NODE_PROPERTIES, import_workflow_from_hue_3_7,\
     find_dollar_variables, find_dollar_braced_variables
     find_dollar_variables, find_dollar_braced_variables
+from oozie.utils import convert_to_server_timezone
 from oozie.views.editor import edit_workflow as old_edit_workflow, edit_coordinator as old_edit_coordinator, edit_bundle as old_edit_bundle
 from oozie.views.editor import edit_workflow as old_edit_workflow, edit_coordinator as old_edit_coordinator, edit_bundle as old_edit_bundle
 
 
 
 
@@ -765,6 +766,11 @@ def _submit_bundle(request, bundle, properties):
       deployment_mapping['coord_%s_dir' % i] = request.fs.get_hdfs_path(coord_dir)
       deployment_mapping['coord_%s_dir' % i] = request.fs.get_hdfs_path(coord_dir)
       deployment_mapping['coord_%s' % i] = coord
       deployment_mapping['coord_%s' % i] = coord
 
 
+      # Convert start/end dates of coordinator to server timezone
+      for prop in bundled['properties']:
+        if prop['name'] in ('end_date', 'start_date'):
+          prop['value'] = convert_to_server_timezone(prop['value'], local_tz=coordinator.data['properties']['timezone'])
+
     properties.update(deployment_mapping)
     properties.update(deployment_mapping)
 
 
     submission = Submission(request.user, bundle, request.fs, request.jt, properties=properties)
     submission = Submission(request.user, bundle, request.fs, request.jt, properties=properties)