Skip to content

Commit

Permalink
Updating S3LogLink with an invalid bucket link (#39424)
Browse files Browse the repository at this point in the history
  • Loading branch information
amoghrajesh committed May 6, 2024
1 parent 4a568d3 commit 9eac305
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion docs/apache-airflow/howto/define-extra-link.rst
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,11 @@ tasks using :class:`~airflow.providers.amazon.aws.transfers.gcs_to_s3.GCSToS3Ope
operators = [GCSToS3Operator]
def get_link(self, operator: BaseOperator, *, ti_key: TaskInstanceKey):
return "https://s3.amazonaws.com/airflow-logs/{dag_id}/{task_id}/{run_id}".format(
# Invalid bucket name because upper case letters and underscores are used
# This will not be a valid bucket in any region
bucket_name = "Invalid_Bucket_Name"
return "https://s3.amazonaws.com/airflow-logs/{bucket_name}/{dag_id}/{task_id}/{run_id}".format(
bucket_name=bucket_name,
dag_id=operator.dag_id,
task_id=operator.task_id,
run_id=ti_key.run_id,
Expand Down

0 comments on commit 9eac305

Please sign in to comment.