code: def returner(ret):
      '''
      Return data to a postgres server
      '''
      try:
          with _get_serv(ret, commit=True) as cur:
              sql = '''INSERT INTO salt_returns
                      (fun, jid, return, id, success, full_ret)
                      VALUES (%s, %s, %s, %s, %s, %s)'''
              cur.execute(
                  sql, (
                      ret['fun'],
                      ret['jid'],
                      salt.utils.json.dumps(ret['return']),
                      ret['id'],
                      ret.get('success', False),
                      salt.utils.json.dumps(ret)))
      except salt.exceptions.SaltMasterError:
          log.critical('Could not store return with postgres returner. PostgreSQL server unavailable.'f returner(ret):
      '''
      Return data to a postgres server
      '''
      try:
          with _get_serv(ret, commit=True) as cur:
              sql = '''INSERT INTO salt_returns
                      (fun, jid, return, id, success, full_ret)
                      VALUES (%s, %s, %s, %s, %s, %s)'''
              cur.execute(
                  sql, (
                      ret['fun'],
                      ret['jid'],
                      salt.utils.json.dumps(ret['return']),
                      ret['id'],
                      ret.get('success', False),
                      salt.utils.json.dumps(ret)))
      except salt.exceptions.SaltMasterError:
          log.critical('Could not store return with postgres returner. PostgreSQL server unavailable.')
docs: Return data to a postgres server