Skip to content

Commit 9559802

Browse files
committed
fix: remove token keyword argument
1 parent eff751a commit 9559802

File tree

2 files changed

+3
-11
lines changed

2 files changed

+3
-11
lines changed

src/DIRAC/Core/Tornado/Client/TornadoClient.py

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ def executeRPC(self, method, *args):
6464
retVal["rpcStub"] = (self._getBaseStub(), method, list(args))
6565
return retVal
6666

67-
def receiveFile(self, destFile, fileId, token=""):
67+
def receiveFile(self, destFile, *args):
6868
"""
6969
Equivalent of :py:meth:`~DIRAC.Core.DISET.TransferClient.TransferClient.receiveFile`
7070
@@ -74,15 +74,7 @@ def receiveFile(self, destFile, fileId, token=""):
7474
:param args: list of arguments
7575
:returns: S_OK/S_ERROR
7676
"""
77-
rpcCall = {
78-
"method": "streamToClient",
79-
"args": encode(
80-
(
81-
fileId,
82-
token,
83-
)
84-
),
85-
}
77+
rpcCall = {"method": "streamToClient", "args": encode(args)}
8678
# Start request
8779
retVal = self._request(outputFile=destFile, **rpcCall)
8880
return retVal

src/DIRAC/Resources/Storage/DIPStorage.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ def getFile(self, path, localPath=False):
160160

161161
def __getFile(self, src_url, dest_file):
162162
transferClient = TransferClient(self.url)
163-
res = transferClient.receiveFile(dest_file, src_url, token=self.checkSum)
163+
res = transferClient.receiveFile(dest_file, src_url, self.checkSum)
164164
if not res["OK"]:
165165
return res
166166
if not os.path.exists(dest_file):

0 commit comments

Comments
 (0)