Fixed folder naming for ingest from deluxe
This commit is contained in:
+1
-1
@@ -58,7 +58,7 @@ def on_command(client: mqtt_client.Client, userdata: Any, msg: mqtt_client.MQTTM
|
||||
unique: str = notify.unique
|
||||
this_server: FTPServer = list(filter(lambda s: unique in s.dirs.keys(), dcp_servers.servers))[0]
|
||||
user_pswd: str = f"{this_server.username}:{this_server.password}" if this_server.username else "anonymous:"
|
||||
dir_name: str = f"{this_server.cwd}{"/" if this_server.cwd else ""}{this_server.dirs[unique].name}"
|
||||
dir_name: str = f"{this_server.cwd if this_server.cwd else ""}{"/" if this_server.cwd else ""}{this_server.dirs[unique].name}"
|
||||
ingest_command: AddImportJob = AddImportJob()
|
||||
assert isinstance(ingest_command.MessageBody, CommandBodyWrapper)
|
||||
ingest_command.MessageBody.Command.ParameterList.Parameter.insert(0,
|
||||
|
||||
Reference in New Issue
Block a user