code: def _conn(commit=False):
      '''
      Return an postgres cursor
      '''
      defaults = {'host': 'localhost',
                  'user': 'salt',
                  'password': 'salt',
                  'dbname': 'salt',
                  'port': 5432}
  
      conn_kwargs = {}
      for key, value in defaults.items():
          conn_kwargs[key] = __opts__.get('queue.{0}.{1}'.format(__virtualname__, key), value)
      try:
          conn = psycopg2.connect(**conn_kwargs)
      except psycopg2.OperationalError as exc:
          raise SaltMasterError('pgjsonb returner could not connect to database: {exc}'.format(exc=exc))
  
      cursor = conn.cursor()
  
      try:
          yield cursor
      except psycopg2.DatabaseError as err:
          error = err.args
          sys.stderr.write(six.text_type(error))
          cursor.execute("ROLLBACK")
          raise err
      else:
          if commit:
              cursor.execute("COMMIT")
          else:
              cursor.execute("ROLLBACK")
      finally:
          conn.close(f _conn(commit=False):
      '''
      Return an postgres cursor
      '''
      defaults = {'host': 'localhost',
                  'user': 'salt',
                  'password': 'salt',
                  'dbname': 'salt',
                  'port': 5432}
  
      conn_kwargs = {}
      for key, value in defaults.items():
          conn_kwargs[key] = __opts__.get('queue.{0}.{1}'.format(__virtualname__, key), value)
      try:
          conn = psycopg2.connect(**conn_kwargs)
      except psycopg2.OperationalError as exc:
          raise SaltMasterError('pgjsonb returner could not connect to database: {exc}'.format(exc=exc))
  
      cursor = conn.cursor()
  
      try:
          yield cursor
      except psycopg2.DatabaseError as err:
          error = err.args
          sys.stderr.write(six.text_type(error))
          cursor.execute("ROLLBACK")
          raise err
      else:
          if commit:
              cursor.execute("COMMIT")
          else:
              cursor.execute("ROLLBACK")
      finally:
          conn.close()
docs: Return an postgres cursor