hunk.code_window:             self.supports_autocommit = True
           return psycopg2_conn
       @staticmethod
       def _serialize_cell(cell):
           return psycopg2.extensions.adapt(cell).getquoted().decode('utf-8')
hunk.labels: keep keep keep keep replace keep
hunk.after_edit:     def _serialize_cell(cell, conn):
           """
           Returns the Postgres literal of the cell as a string.
           :param cell: The cell to insert into the table
           :type cell: object
           :param conn: The database connection
           :type conn: connection object
           :return: The serialized cell
           :rtype: str
           """
  
hunk.file_path: airflow/hooks/postgres_hook.py
hunk.type: replace
file: #
  # Licensed under the Apache License, Version 2.0 (the "License");
  # you may not use this file except in compliance with the License.
  # You may obtain a copy of the License at
  #
  # http://www.apache.org/licenses/LICENSE-2.0
  #
  # Unless required by applicable law or agreed to in writing, software
  # distributed under the License is distributed on an "AS IS" BASIS,
  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  # See the License for the specific language governing permissions and
  # limitations under the License.
  
  [core]
  airflow_home = ~/airflow
  dags_folder = ~/airflow/dags
  base_log_folder = ~/airflow/logs
  executor = LocalExecutor
  sql_alchemy_conn = mysql://root@localhost/airflow
  unit_test_mode = True
  load_examples = True
  donot_pickle = False
  dag_concurrency = 16
  dags_are_paused_at_creation = False
  fernet_key = af7CN0q6ag5U3g08IsPsw3K45U7Xa0axgVFhoh-3zB8=
  
  [webserver]
  base_url = http://localhost:8080
  web_server_host = 0.0.0.0
  web_server_port = 8080
  
  [email]
  email_backend = airflow.utils.send_email_smtp
  
  [smtp]
  smtp_host = localhost
  smtp_user = airflow
  smtp_port = 25
  smtp_password = airflow
  smtp_mail_from = airflow@airflow.com
  
  [celery]
  celery_app_name = airflow.executors.celery_executor
  celeryd_concurrency = 16
  worker_log_server_port = 8793
  broker_url = sqla+mysql://airflow:airflow@localhost:3306/airflow
  celery_result_backend = db+mysql://airflow:airflow@localhost:3306/airflow
  flower_port = 5555
  default_queue = default
  
  [scheduler]
  job_heartbeat_sec = 1
  scheduler_heartbeat_sec = 5
  authenticate = true
  max_threads = 2
  
  