in o2a/mappers/distcp_mapper.py [0:0]
def _parse_args(self):
args = []
arg_nodes = xml_utils.find_nodes_by_tag(self.oozie_node, "arg")
if arg_nodes:
for node in arg_nodes:
value: str = node.text
if "/" in value:
# If an argument contains a forward slash then it's a URL.
# The full URL should be preserved when replacing the EL (and not just the path)
# to enable copying files between two different clusters.
value = el_utils.replace_url_el(value, props=self.props)
value = shlex.quote(value)
args.append(value)
return " ".join(args)