|
@@ -106,9 +106,13 @@ class OozieApi:
|
|
|
params=json.dumps(pig_params),
|
|
params=json.dumps(pig_params),
|
|
|
files=json.dumps(files),
|
|
files=json.dumps(files),
|
|
|
archives=json.dumps(archives),
|
|
archives=json.dumps(archives),
|
|
|
- job_properties=json.dumps(job_properties),
|
|
|
|
|
|
|
+ job_properties=json.dumps(job_properties)
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
|
|
+ if pig_script.use_hcatalog and get_oozie(self.user).security_enabled:
|
|
|
|
|
+ action.credentials = [{'name': 'hcat', 'value': True}]
|
|
|
|
|
+ action.save()
|
|
|
|
|
+
|
|
|
action.add_node(workflow.end)
|
|
action.add_node(workflow.end)
|
|
|
|
|
|
|
|
start_link = workflow.start.get_link()
|
|
start_link = workflow.start.get_link()
|