Skip to content

Commit 03e9b86

Browse files
authored
Added logging to fastly purge flow (boostorg#1873) (boostorg#1887)
1 parent a42b024 commit 03e9b86

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

versions/tasks.py

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,9 @@ def import_versions(
6666

6767
if import_version_task_group:
6868
task_group = group(*import_version_task_group)
69+
logger.info(f"{purge_after=}")
6970
if purge_after:
71+
logger.info("linking fastly purge")
7072
task_group.link(purge_fastly_release_cache.s())
7173
task_group()
7274
import_release_notes.delay()
@@ -461,6 +463,7 @@ def get_release_date_for_version(version_pk, commit_sha, token=None):
461463

462464
@app.task
463465
def purge_fastly_release_cache():
466+
logger.info("Purging Fastly cache for release pages.")
464467
if not settings.FASTLY_API_TOKEN or settings.FASTLY_API_TOKEN == "empty":
465468
logger.warning("FASTLY_API_TOKEN not found. Not purging cache.")
466469
return
@@ -470,11 +473,15 @@ def purge_fastly_release_cache():
470473
"Fastly-Soft-Purge": "1",
471474
"Accept": "application/json",
472475
}
473-
474-
for service in [settings.FASTLY_SERVICE, settings.FASTLY_SERVICE2]:
476+
fastly_services = [settings.FASTLY_SERVICE, settings.FASTLY_SERVICE2]
477+
logger.info(f"{fastly_services=}")
478+
for service in fastly_services:
479+
logger.info(f"Purging Fastly cache for release pages against {service=}")
475480
if not service or service == "empty":
481+
logger.warning(f"Fastly {service=} not found. Not purging cache.")
476482
continue
477483
url = f"https://api.fastly.com/service/{service}/purge/release"
484+
logger.info(f"Purging Fastly cache for {service=} at {url=}")
478485
requests.post(url, headers=headers)
479486
logger.info(f"Sent fastly purge request for {service=}.")
480487

0 commit comments

Comments
 (0)