瀏覽代碼

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

Note: This fix is needed because of HUE-1910
krish 9 年之前
父節點
當前提交
d11af65f50
共有 1 個文件被更改,包括 6 次插入0 次删除
  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)