Task to Trigger Google Cloud Function

[marvin-robot]

Archived from the Prefect Public Slack Community

mattalhonte: Made a new version of the Task that triggers Google Cloud Functions - this one will actually fail if the Cloud Function doesn't work (my last version failed silently)

@task(max_retries=3, retry_delay=datetime.timedelta(seconds=30))
def trigger_cloud_fn(secret: PrefectSecret, url: str, body: str = "{}"):
    logger = prefect.context.get("logger")
    <http://logger.info|logger.info>(body)
    credentials = service_account.IDTokenCredentials.from_service_account_info(
        secret, target_audience=url
    )
    authed_session = AuthorizedSession(credentials)
    response = <http://authed_session.post|authed_session.post>(url=url, json=body)
    if not (isinstance(response, requests.models.Response) and response.ok):
        raise signals.FAIL()
    authed_session.close()
    return response

mattalhonte: I think logging the request body is also useful, cuz then you know which ones caused errors!

kevin701: <@ULVA73B9P> archive “Task to Trigger Google Cloud Function”"

marvin2: #4835

Original thread can be found here.

[kvnkho]

This was a duplicate due to an edit.