def _upload_workflow_file(self, where, job_dir, wf_xml, hdfs_user):
        with remote.get_remote(where) as r:
            h.put_file_to_hdfs(r, wf_xml, "workflow.xml", job_dir, hdfs_user)
        return "%s/workflow.xml" % job_dir
dataset/ETHPy150Open openstack/sahara/sahara/service/edp/oozie/engine.py/OozieJobEngine._upload_workflow_file/original