Skip to content

Commit

Permalink
Move to Google MySQL
Browse files Browse the repository at this point in the history
  • Loading branch information
greg-finley committed Mar 7, 2024
1 parent 2ff8b1a commit ded4f98
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 6 deletions.
3 changes: 1 addition & 2 deletions process_file/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,10 @@
mysql_config_dict = json.loads(mysql_config_str)

mysql_connection = mysql.connector.connect(
host=mysql_config_dict["MYSQL_HOST"],
unix_socket=mysql_config["MYSQL_SOCKET"],
user=mysql_config_dict["MYSQL_USERNAME"],
passwd=mysql_config_dict["MYSQL_PASSWORD"],
database=mysql_config_dict["MYSQL_DATABASE"],
ssl_ca=os.environ.get("SSL_CERT_FILE", "/etc/ssl/certs/ca-certificates.crt"),
)
mysql_connection.autocommit = True

Expand Down
3 changes: 1 addition & 2 deletions queue_files/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,11 +15,10 @@
mysql_config = json.loads(os.environ["MYSQL_CONFIG"])

mysql_connection = mysql.connector.connect(
host=mysql_config["MYSQL_HOST"],
unix_socket=mysql_config["MYSQL_SOCKET"],
user=mysql_config["MYSQL_USERNAME"],
passwd=mysql_config["MYSQL_PASSWORD"],
database=mysql_config["MYSQL_DATABASE"],
ssl_ca=os.environ.get("SSL_CERT_FILE", "/etc/ssl/certs/ca-certificates.crt"),
)
mysql_connection.autocommit = True

Expand Down
3 changes: 1 addition & 2 deletions requeue_failed_files/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,10 @@
mysql_config = json.loads(os.environ["MYSQL_CONFIG"])

mysql_connection = mysql.connector.connect(
host=mysql_config["MYSQL_HOST"],
unix_socket=mysql_config["MYSQL_SOCKET"],
user=mysql_config["MYSQL_USERNAME"],
passwd=mysql_config["MYSQL_PASSWORD"],
database=mysql_config["MYSQL_DATABASE"],
ssl_ca=os.environ.get("SSL_CERT_FILE", "/etc/ssl/certs/ca-certificates.crt"),
)
mysql_connection.autocommit = True
secret_client = secretmanager.SecretManagerServiceClient()
Expand Down

0 comments on commit ded4f98

Please sign in to comment.