pacsretrieve/pacsretrieve.py
def retrieveStatus_process(self, al_checkCall, **kwargs):
        """
        Process the retrieve status by waiting until 
        all asynchronous retrieves have completed.
        """
        
        b_jobsPending           = True
        b_breakCondition        = False
        b_waitForPending        = True
        sleepInterval           = 5
        l_retrieveStatus        = []
        l_checkCall             = []

        self.l_retrieveOK       = []

        for k, v in kwargs.items():
            if k == 'waitForPending':   b_waitForPending = v

        # pudb.set_trace()

        d_ret                   = self.retrieveStatus_callAndFilter(al_checkCall)
        b_jobsPending           = d_ret['status']
        for done in d_ret['doneResults']: self.l_retrieveOK.append(done)
        self.dp.qprint('Done list len = %d' % len(self.l_retrieveOK))

        while b_jobsPending and not b_breakCondition and b_waitForPending:
            self.dp.qprint('Pending retrieve jobs detected. Sleeping for %d seconds...' % sleepInterval)
            time.sleep(sleepInterval)

            self.dp.qprint('Reprocessing retrieve status for pending jobs...')
            d_ret               = self.retrieveStatus_callAndFilter(d_ret['pendingCalls'])
            b_jobsPending       = d_ret['status']

            # Update a master list of done results...
            for done in d_ret['doneResults']: self.l_retrieveOK.append(done)
            self.dp.qprint('Done list len = %d' % len(self.l_retrieveOK))
        
        return d_ret

        Process the retrieve status by waiting until 
        all asynchronous retrieves have completed.
        
Process the retrieve status by waiting until
all asynchronous retrieves have completed.
Process the retrieve status by waiting until all asynchronous retrieves have completed .
def retrieveStatus_process(self, al_checkCall, **kwargs):
        b_jobsPending           = True
        b_breakCondition        = False
        b_waitForPending        = True
        sleepInterval           = 5
        l_retrieveStatus        = []
        l_checkCall             = []
        self.l_retrieveOK       = []
        for k, v in kwargs.items():
            if k == 'waitForPending':   b_waitForPending = v
        d_ret                   = self.retrieveStatus_callAndFilter(al_checkCall)
        b_jobsPending           = d_ret['status']
        for done in d_ret['doneResults']: self.l_retrieveOK.append(done)
        self.dp.qprint('Done list len = %d' % len(self.l_retrieveOK))
        while b_jobsPending and not b_breakCondition and b_waitForPending:
            self.dp.qprint('Pending retrieve jobs detected. Sleeping for %d seconds...' % sleepInterval)
            time.sleep(sleepInterval)
            self.dp.qprint('Reprocessing retrieve status for pending jobs...')
            d_ret               = self.retrieveStatus_callAndFilter(d_ret['pendingCalls'])
            b_jobsPending       = d_ret['status']
            for done in d_ret['doneResults']: self.l_retrieveOK.append(done)
            self.dp.qprint('Done list len = %d' % len(self.l_retrieveOK))
        return d_ret
def retrieveStatus_process ( self , al_checkCall , ** kwargs ) : b_jobsPending = True b_breakCondition = False b_waitForPending = True sleepInterval = 5 l_retrieveStatus = [ ] l_checkCall = [ ] self . l_retrieveOK = [ ] for k , v in kwargs . items ( ) : if k == 'waitForPending' : b_waitForPending = v d_ret = self . retrieveStatus_callAndFilter ( al_checkCall ) b_jobsPending = d_ret [ 'status' ] for done in d_ret [ 'doneResults' ] : self . l_retrieveOK . append ( done ) self . dp . qprint ( 'Done list len = %d' % len ( self . l_retrieveOK ) ) while b_jobsPending and not b_breakCondition and b_waitForPending : self . dp . qprint ( 'Pending retrieve jobs detected. Sleeping for %d seconds...' % sleepInterval ) time . sleep ( sleepInterval ) self . dp . qprint ( 'Reprocessing retrieve status for pending jobs...' ) d_ret = self . retrieveStatus_callAndFilter ( d_ret [ 'pendingCalls' ] ) b_jobsPending = d_ret [ 'status' ] for done in d_ret [ 'doneResults' ] : self . l_retrieveOK . append ( done ) self . dp . qprint ( 'Done list len = %d' % len ( self . l_retrieveOK ) ) return d_ret
Process the retrieve status by waiting until
all asynchronous retrieves have completed.
Process the retrieve status by waiting until all asynchronous retrieves have completed .
"""
        Process the retrieve status by waiting until 
        all asynchronous retrieves have completed.
        """ # pudb.set_trace() # Update a master list of done results...
self
al_checkCall