resp = self.obsClient.putFile(bucketname, inname, local_file)
File "/root/airflow/dags/obs/client.py", line 152, in wrapper
raise e
File "/root/airflow/dags/obs/client.py", line 148, in wrapper
ret = func(*args, **kwargs)
File "/root/airflow/dags/obs/client.py", line 1779, in putFile
methodName='putContent', readable=readable, extensionHeaders=extensionHeaders)
File "/root/airflow/dags/obs/client.py", line 438, in _make_put_request
extensionHeaders=extensionHeaders)
File "/root/airflow/dags/obs/client.py", line 481, in _make_request_with_retry
return self._make_error_result(e, ret)
File "/root/airflow/dags/obs/client.py", line 445, in _make_error_result
raise e
File "/root/airflow/dags/obs/client.py", line 460, in _make_request_with_retry
extensionHeaders=extensionHeaders)
File "/root/airflow/dags/obs/client.py", line 536, in _make_request_internal
chunkedMode)
File "/root/airflow/dags/obs/client.py", line 704, in _send_request
entity(util.conn_delegate(conn))
File "/root/airflow/dags/obs/util.py", line 223, in entity
chunk = readable.read(readCountOnce)
ValueError: read of closed file
resp = self.obsClient.putFile(bucketname, inname, local_file) File "/root/airflow/dags/obs/client.py", line 152, in wrapper raise e File "/root/airflow/dags/obs/client.py", line 148, in wrapper ret = func(*args, **kwargs) File "/root/airflow/dags/obs/client.py", line 1779, in putFile methodName='putContent', readable=readable, extensionHeaders=extensionHeaders) File "/root/airflow/dags/obs/client.py", line 438, in _make_put_request extensionHeaders=extensionHeaders) File "/root/airflow/dags/obs/client.py", line 481, in _make_request_with_retry return self._make_error_result(e, ret) File "/root/airflow/dags/obs/client.py", line 445, in _make_error_result raise e File "/root/airflow/dags/obs/client.py", line 460, in _make_request_with_retry extensionHeaders=extensionHeaders) File "/root/airflow/dags/obs/client.py", line 536, in _make_request_internal chunkedMode) File "/root/airflow/dags/obs/client.py", line 704, in _send_request entity(util.conn_delegate(conn)) File "/root/airflow/dags/obs/util.py", line 223, in entity chunk = readable.read(readCountOnce) ValueError: read of closed file