We are currently solving the following issue within our repository. Here is the issue text:
--- BEGIN ISSUE ---
Use standard AWS environment variables
**Context**
At the moment, Astro 0.6.x uses a custom environment variable `AIRFLOW__ASTRO__CONN_AWS_DEFAULT` to define AWS credentials. However, there are standard [AWS environment variables to define credentials](https://boto3.amazonaws.com/v1/documentation/api/latest/guide/configuration.html#using-environment-variables).

**Acceptance criteria**
* Replace any occurrence of `AIRFLOW__ASTRO__CONN_AWS_DEFAULT`  by `AWS_ACCESS_KEY_ID` and `AWS_SECRET_ACCESS_KEY`

--- END ISSUE ---

Below are some code segments, each from a relevant file. One or more of these files may contain bugs.
--- BEGIN FILES ---
Path: `src/astro/utils/cloud_storage_creds.py`
Content:
```
1 import json
2 import os
3 from urllib import parse
4 
5 from airflow.hooks.base import BaseHook
6 
7 from astro.utils.dependencies import (
8     AwsBaseHook,
9     BotoSession,
10     GCSClient,
11     GCSHook,
12     google_service_account,
13 )
14 
15 
16 def parse_s3_env_var():
17     raw_data = (
18         os.environ["AIRFLOW__ASTRO__CONN_AWS_DEFAULT"]
19         .replace("%2F", "/")
20         .replace("aws://", "")
21         .replace("@", "")
22         .split(":")
23     )
24     return [parse.unquote(r) for r in raw_data]
25 
26 
27 def s3fs_creds(conn_id=None):
28     """Structure s3fs credentials from Airflow connection.
29     s3fs enables pandas to write to s3
30     """
31     if conn_id:
32         # The following line raises a friendly exception
33         BaseHook.get_connection(conn_id)
34         aws_hook = AwsBaseHook(conn_id, client_type="S3")
35         session = aws_hook.get_session()
36     else:
37         key, secret = parse_s3_env_var()
38         session = BotoSession(
39             aws_access_key_id=key,
40             aws_secret_access_key=secret,
41         )
42     return dict(client=session.client("s3"))
43 
44 
45 def gcs_client(conn_id=None):
46     """
47     get GCS credentials for storage.
48     """
49     if conn_id:
50         gcs_hook = GCSHook(conn_id)
51         client = gcs_hook.get_conn()
52     else:
53         client = GCSClient()
54 
55     return dict(client=client)
56
```
--- END FILES ---

Please first localize the bug based on the issue statement, and then generate a patch according to the `git diff` format fenced by three backticks.

Here is an example:

```diff
diff --git a/examples/server_async.py b/examples/server_async.py
--- a/examples/server_async.py
+++ b/examples/server_async.py
@@ -313,4 +313,4 @@
 
 
 if __name__ == "__main__":
-    asyncio.run(run_async_server("."), debug=True)
+    asyncio.run(run_async_server(), debug=True)
diff --git a/examples/server_sync.py b/examples/server_sync.py
--- a/examples/server_sync.py
+++ b/examples/server_sync.py
@@ -313,5 +313,5 @@
 
 
 if __name__ == "__main__":
-    server = run_sync_server(".")
+    server = run_sync_server()
     server.shutdown()

```

diff --git a/src/astro/utils/cloud_storage_creds.py b/src/astro/utils/cloud_storage_creds.py
--- a/src/astro/utils/cloud_storage_creds.py
+++ b/src/astro/utils/cloud_storage_creds.py
@@ -14,14 +14,7 @@
 
 
 def parse_s3_env_var():
-    raw_data = (
-        os.environ["AIRFLOW__ASTRO__CONN_AWS_DEFAULT"]
-        .replace("%2F", "/")
-        .replace("aws://", "")
-        .replace("@", "")
-        .split(":")
-    )
-    return [parse.unquote(r) for r in raw_data]
+    return os.environ["AWS_ACCESS_KEY_ID"], os.environ["AWS_SECRET_ACCESS_KEY"]
 
 
 def s3fs_creds(conn_id=None):

{"golden_diff": "diff --git a/src/astro/utils/cloud_storage_creds.py b/src/astro/utils/cloud_storage_creds.py\n--- a/src/astro/utils/cloud_storage_creds.py\n+++ b/src/astro/utils/cloud_storage_creds.py\n@@ -14,14 +14,7 @@\n \n \n def parse_s3_env_var():\n-    raw_data = (\n-        os.environ[\"AIRFLOW__ASTRO__CONN_AWS_DEFAULT\"]\n-        .replace(\"%2F\", \"/\")\n-        .replace(\"aws://\", \"\")\n-        .replace(\"@\", \"\")\n-        .split(\":\")\n-    )\n-    return [parse.unquote(r) for r in raw_data]\n+    return os.environ[\"AWS_ACCESS_KEY_ID\"], os.environ[\"AWS_SECRET_ACCESS_KEY\"]\n \n \n def s3fs_creds(conn_id=None):\n", "issue": "Use standard AWS environment variables\n**Context**\r\nAt the moment, Astro 0.6.x uses a custom environment variable `AIRFLOW__ASTRO__CONN_AWS_DEFAULT` to define AWS credentials. However, there are standard [AWS environment variables to define credentials](https://boto3.amazonaws.com/v1/documentation/api/latest/guide/configuration.html#using-environment-variables).\r\n\r\n**Acceptance criteria**\r\n* Replace any occurrence of `AIRFLOW__ASTRO__CONN_AWS_DEFAULT`  by `AWS_ACCESS_KEY_ID` and `AWS_SECRET_ACCESS_KEY`\n", "before_files": [{"content": "import json\nimport os\nfrom urllib import parse\n\nfrom airflow.hooks.base import BaseHook\n\nfrom astro.utils.dependencies import (\n    AwsBaseHook,\n    BotoSession,\n    GCSClient,\n    GCSHook,\n    google_service_account,\n)\n\n\ndef parse_s3_env_var():\n    raw_data = (\n        os.environ[\"AIRFLOW__ASTRO__CONN_AWS_DEFAULT\"]\n        .replace(\"%2F\", \"/\")\n        .replace(\"aws://\", \"\")\n        .replace(\"@\", \"\")\n        .split(\":\")\n    )\n    return [parse.unquote(r) for r in raw_data]\n\n\ndef s3fs_creds(conn_id=None):\n    \"\"\"Structure s3fs credentials from Airflow connection.\n    s3fs enables pandas to write to s3\n    \"\"\"\n    if conn_id:\n        # The following line raises a friendly exception\n        BaseHook.get_connection(conn_id)\n        aws_hook = AwsBaseHook(conn_id, client_type=\"S3\")\n        session = aws_hook.get_session()\n    else:\n        key, secret = parse_s3_env_var()\n        session = BotoSession(\n            aws_access_key_id=key,\n            aws_secret_access_key=secret,\n        )\n    return dict(client=session.client(\"s3\"))\n\n\ndef gcs_client(conn_id=None):\n    \"\"\"\n    get GCS credentials for storage.\n    \"\"\"\n    if conn_id:\n        gcs_hook = GCSHook(conn_id)\n        client = gcs_hook.get_conn()\n    else:\n        client = GCSClient()\n\n    return dict(client=client)\n", "path": "src/astro/utils/cloud_storage_creds.py"}], "after_files": [{"content": "import json\nimport os\nfrom urllib import parse\n\nfrom airflow.hooks.base import BaseHook\n\nfrom astro.utils.dependencies import (\n    AwsBaseHook,\n    BotoSession,\n    GCSClient,\n    GCSHook,\n    google_service_account,\n)\n\n\ndef parse_s3_env_var():\n    return os.environ[\"AWS_ACCESS_KEY_ID\"], os.environ[\"AWS_SECRET_ACCESS_KEY\"]\n\n\ndef s3fs_creds(conn_id=None):\n    \"\"\"Structure s3fs credentials from Airflow connection.\n    s3fs enables pandas to write to s3\n    \"\"\"\n    if conn_id:\n        # The following line raises a friendly exception\n        BaseHook.get_connection(conn_id)\n        aws_hook = AwsBaseHook(conn_id, client_type=\"S3\")\n        session = aws_hook.get_session()\n    else:\n        key, secret = parse_s3_env_var()\n        session = BotoSession(\n            aws_access_key_id=key,\n            aws_secret_access_key=secret,\n        )\n    return dict(client=session.client(\"s3\"))\n\n\ndef gcs_client(conn_id=None):\n    \"\"\"\n    get GCS credentials for storage.\n    \"\"\"\n    if conn_id:\n        gcs_hook = GCSHook(conn_id)\n        client = gcs_hook.get_conn()\n    else:\n        client = GCSClient()\n\n    return dict(client=client)\n", "path": "src/astro/utils/cloud_storage_creds.py"}]}