Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/fix_unjustified_xfails' into fix…
Browse files Browse the repository at this point in the history
…_unjustified_xfails
  • Loading branch information
Selfeer committed Dec 22, 2023
2 parents 180db71 + 91fa1d5 commit 4eb5ac1
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,11 @@ def init_sink_connector(
description="""Sending sink settings push command on bash_tools""",
):
command = node.cmd(f"{sink_settings_transfer_command_confluent}")
assert command.output.strip().startswith('{"name":"sink-connector"'), error()
assert command.output.strip().startswith(
'{"name":"sink-connector"'
) or command.output.strip().startswith(
'{"error_code":409,"message":"Connector sink-connector already exists"}'
), error()
yield
finally:
with Finally("I delete sink and debezium connections"):
Expand Down

0 comments on commit 4eb5ac1

Please sign in to comment.