Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Output sql_raw, prepared statement does not exist err #243

Open
nakastoev opened this issue Feb 18, 2025 · 0 comments
Open

Output sql_raw, prepared statement does not exist err #243

nakastoev opened this issue Feb 18, 2025 · 0 comments

Comments

@nakastoev
Copy link

My config looks like:

input:
    sql_raw:
      driver: postgres
      dsn: postgres://${POSTGRES_USER}:${POSTGRES_PASS}@${POSTGRES_HOST}:${POSTGRES_PORT}/${POSTGRES_DB_NAME}?sslmode=disable
      query: "SELECT id FROM partner where dt_update < NOW()::date order by id"

  output:
    sql_raw:
      driver: postgres
      dsn: postgres://${POSTGRES_USER}:${POSTGRES_PASS}@${POSTGRES_HOST}:${POSTGRES_PORT}/${POSTGRES_DB_NAME}?sslmode=disable
      query: "UPDATE partner SET dt_update = NOW() where id = $1"
      args_mapping: |
          root = [
            this.id,
          ]

When I run it (in docker if that matters), i see some level=error msg="Failed to send message to sql_raw: pq: unnamed prepared statement does not exist" @service=bento label="" path=root.output logs, however, records in db are modified correctly

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant