Skip to content

dataArchiver fails to send request

Schenario:

  • dataArchiver performs a cstore request for the user curban with success
  • After that if we recall it for another user it gets stuck
client@661c833968b3:~$ python3 dataArchiverCli.py cstore curban

Sending CSTORE request...

WARNING!!! WARNING!!! WARNING!!! WARNING!!! WARNING!!!
If you confirm, all your data on the transfer node will be
available in read-only mode for all the time the archiving
process is running.
WARNING!!! WARNING!!! WARNING!!! WARNING!!! WARNING!!!

Are you sure to proceed? [yes/no]: yes

JobID: 84119d0c393b11ebb6f20242ac120006
Store process started successfully!                                                                                                               
                                                                                                                                                  
client@661c833968b3:~$ python3 dataArchiverCli.py cstore sbertocco
                                                                                                                                                  
Sending CSTORE request...                                                                                                                         
^CTraceback (most recent call last):                                                                                          
  File "/home/client/dataArchiverCli.py", line 109, in <module>                                                                                   
    dataArchiverCli.store(cmd, username)                                                                                                          
  File "/home/client/dataArchiverCli.py", line 65, in store                                                                                       
    storeResponse = self.call(storeRequest)                                                                                                       
  File "/home/client/dataArchiverCli.py", line 32, in call                                                                                        
    self.connection.process_data_events()                                                                                                         
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 828, in process_data_events                   
    self._flush_output(timer.is_ready, common_terminator)
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 513, in _flush_output
    self._impl.ioloop.poll()
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/select_connection.py", line 576, in poll
    self._poller.poll()
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/select_connection.py", line 1181, in poll
    events = self._poll.poll(self._get_max_wait())
KeyboardInterrupt

client@661c833968b3:~$ python3 dataArchiverCli.py cstore sbertocco

Sending CSTORE request...
^CTraceback (most recent call last):
  File "/home/client/dataArchiverCli.py", line 109, in <module>
    dataArchiverCli.store(cmd, username)
  File "/home/client/dataArchiverCli.py", line 65, in store
    storeResponse = self.call(storeRequest)
  File "/home/client/dataArchiverCli.py", line 32, in call
    self.connection.process_data_events()
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 828, in process_data_events
    self._flush_output(timer.is_ready, common_terminator)
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 512, in _flush_output
    while not is_done():
  File "/home/client/.local/lib/python3.9/site-packages/pika/adapters/blocking_connection.py", line 509, in <lambda>
    (not waiters or any(ready() for ready in waiters))))
KeyboardInterrupt