Update nightly org deletion tests to account for bg job (#2118)
Follow-up to https://github.com/webrecorder/browsertrix/pull/2098 Updates I missed to nightly org deletion tests following the shift to deleting orgs in a background job. I think this should be the last thing to get nightly tests passing consistently again.
This commit is contained in:
		
							parent
							
								
									3ea20e538d
								
							
						
					
					
						commit
						0dc025e9fd
					
				| @ -141,10 +141,38 @@ def test_delete_org_crawl_running( | |||||||
|         f"{API_PREFIX}/orgs/{non_default_org_id}", headers=admin_auth_headers |         f"{API_PREFIX}/orgs/{non_default_org_id}", headers=admin_auth_headers | ||||||
|     ) |     ) | ||||||
|     assert r.status_code == 200 |     assert r.status_code == 200 | ||||||
|     assert r.json()["deleted"] |     data = r.json() | ||||||
|  |     assert data["deleted"] | ||||||
| 
 | 
 | ||||||
|     time.sleep(5) |     job_id = data["id"] | ||||||
| 
 | 
 | ||||||
|  |     # Check that background job is launched and eventually succeeds | ||||||
|  |     max_attempts = 18 | ||||||
|  |     attempts = 1 | ||||||
|  |     while True: | ||||||
|  |         try: | ||||||
|  |             r = requests.get( | ||||||
|  |                 f"{API_PREFIX}/orgs/all/jobs/{job_id}", headers=admin_auth_headers | ||||||
|  |             ) | ||||||
|  |             assert r.status_code == 200 | ||||||
|  |             success = r.json()["success"] | ||||||
|  | 
 | ||||||
|  |             if success: | ||||||
|  |                 break | ||||||
|  | 
 | ||||||
|  |             if success is False: | ||||||
|  |                 assert False | ||||||
|  | 
 | ||||||
|  |             if attempts >= max_attempts: | ||||||
|  |                 assert False | ||||||
|  | 
 | ||||||
|  |             time.sleep(10) | ||||||
|  |         except: | ||||||
|  |             pass | ||||||
|  | 
 | ||||||
|  |         attempts += 1 | ||||||
|  | 
 | ||||||
|  |     # Check that org was deleted | ||||||
|     r = requests.get(f"{API_PREFIX}/orgs", headers=admin_auth_headers) |     r = requests.get(f"{API_PREFIX}/orgs", headers=admin_auth_headers) | ||||||
|     data = r.json() |     data = r.json() | ||||||
|     for org in data["items"]: |     for org in data["items"]: | ||||||
| @ -159,10 +187,38 @@ def test_delete_org_qa_running( | |||||||
|         f"{API_PREFIX}/orgs/{non_default_org_id}", headers=admin_auth_headers |         f"{API_PREFIX}/orgs/{non_default_org_id}", headers=admin_auth_headers | ||||||
|     ) |     ) | ||||||
|     assert r.status_code == 200 |     assert r.status_code == 200 | ||||||
|     assert r.json()["deleted"] |     data = r.json() | ||||||
|  |     assert data["deleted"] | ||||||
| 
 | 
 | ||||||
|     time.sleep(5) |     job_id = data["id"] | ||||||
| 
 | 
 | ||||||
|  |     # Check that background job is launched and eventually succeeds | ||||||
|  |     max_attempts = 18 | ||||||
|  |     attempts = 1 | ||||||
|  |     while True: | ||||||
|  |         try: | ||||||
|  |             r = requests.get( | ||||||
|  |                 f"{API_PREFIX}/orgs/all/jobs/{job_id}", headers=admin_auth_headers | ||||||
|  |             ) | ||||||
|  |             assert r.status_code == 200 | ||||||
|  |             success = r.json()["success"] | ||||||
|  | 
 | ||||||
|  |             if success: | ||||||
|  |                 break | ||||||
|  | 
 | ||||||
|  |             if success is False: | ||||||
|  |                 assert False | ||||||
|  | 
 | ||||||
|  |             if attempts >= max_attempts: | ||||||
|  |                 assert False | ||||||
|  | 
 | ||||||
|  |             time.sleep(10) | ||||||
|  |         except: | ||||||
|  |             pass | ||||||
|  | 
 | ||||||
|  |         attempts += 1 | ||||||
|  | 
 | ||||||
|  |     # Check that org was deleted | ||||||
|     r = requests.get(f"{API_PREFIX}/orgs", headers=admin_auth_headers) |     r = requests.get(f"{API_PREFIX}/orgs", headers=admin_auth_headers) | ||||||
|     data = r.json() |     data = r.json() | ||||||
|     for org in data["items"]: |     for org in data["items"]: | ||||||
| @ -177,10 +233,38 @@ def test_delete_org_profile_running( | |||||||
|         f"{API_PREFIX}/orgs/{non_default_org_id}", headers=admin_auth_headers |         f"{API_PREFIX}/orgs/{non_default_org_id}", headers=admin_auth_headers | ||||||
|     ) |     ) | ||||||
|     assert r.status_code == 200 |     assert r.status_code == 200 | ||||||
|     assert r.json()["deleted"] |     data = r.json() | ||||||
|  |     assert data["deleted"] | ||||||
| 
 | 
 | ||||||
|     time.sleep(5) |     job_id = data["id"] | ||||||
| 
 | 
 | ||||||
|  |     # Check that background job is launched and eventually succeeds | ||||||
|  |     max_attempts = 18 | ||||||
|  |     attempts = 1 | ||||||
|  |     while True: | ||||||
|  |         try: | ||||||
|  |             r = requests.get( | ||||||
|  |                 f"{API_PREFIX}/orgs/all/jobs/{job_id}", headers=admin_auth_headers | ||||||
|  |             ) | ||||||
|  |             assert r.status_code == 200 | ||||||
|  |             success = r.json()["success"] | ||||||
|  | 
 | ||||||
|  |             if success: | ||||||
|  |                 break | ||||||
|  | 
 | ||||||
|  |             if success is False: | ||||||
|  |                 assert False | ||||||
|  | 
 | ||||||
|  |             if attempts >= max_attempts: | ||||||
|  |                 assert False | ||||||
|  | 
 | ||||||
|  |             time.sleep(10) | ||||||
|  |         except: | ||||||
|  |             pass | ||||||
|  | 
 | ||||||
|  |         attempts += 1 | ||||||
|  | 
 | ||||||
|  |     # Check that org was deleted | ||||||
|     r = requests.get(f"{API_PREFIX}/orgs", headers=admin_auth_headers) |     r = requests.get(f"{API_PREFIX}/orgs", headers=admin_auth_headers) | ||||||
|     data = r.json() |     data = r.json() | ||||||
|     for org in data["items"]: |     for org in data["items"]: | ||||||
|  | |||||||
		Loading…
	
		Reference in New Issue
	
	Block a user