delete_process

Description

Completely removes all records for a process from the databases. A running process can't be deleted.

Arguments:

'api_key' 'experiment_id'

Simple Example

        #start job running
        [status,eid] = TestLaunchFinancialProcess.launch_a_test_process(self,2)
        print(status)
        self.assertEqual(status,'running', 'Process is not running, status = ' + str(status))

        #attempt to delete running process, which should not be possible
        pq.delete_process(q={'api_key':api_key,'experiment_id':eid},remote=True)           
        q = { 'api_key' : api_key,'query':{'experiment_id':eid}}
        dat = pq.find_processes(q,remote=True)
        self.assertTrue(len(dat)>1, 'process appears to have been deleted' )

        # now we halt process, delete it, and check that get_last_logs returns an empty structure
        pq.halt_process({'api_key':api_key,'experiment_id':eid})    
        time.sleep(pause)
        q = { 'api_key' : api_key,'query':{'experiment_id':eid}}
        dat = pq.find_processes(q,remote=True)
        try:
            status = list(pd.DataFrame(dat)['status'])[0]
        except Exception as e:
            print(dat)
            raise e 
        self.assertEqual(status,'halted',"job status should be 'halted'")
        pq.delete_process(q={'api_key':api_key,'experiment_id':eid},remote=True)           
        q = { 'api_key' : api_key,'query':{'experiment_id':eid}}
        dat = pq.find_processes(q,remote=True)
        self.assertEqual(len(dat),0, 'process could not be deleted' ) 
        dat = pq.get_last_logs( {'api_key':api_key,'experiment_id':eid}, remote=True )
        self.assertEqual(len(dat),0, 'last logs from deleted process should be empty' )

Simple Example Output

Failure Examples

attempted deletion of a running process is covered in previous example

Failure Examples Output

Three Examples

not implemented

Three Examples Output