diff --git a/src/pubsub.py b/src/pubsub.py
index 07b1ec29..d44daf3f 100644
--- a/src/pubsub.py
+++ b/src/pubsub.py
@@ -183,7 +183,7 @@ def __init__(
 
         # additional parameters
         if params:
-            query += " with ({})".format(options_string(**params))
+            query += " with ({})".format(options_string(separator=", ", **params))
 
         # Note: cannot run 'create subscription' query in transaction mode
         self.node.execute(
diff --git a/tests/test_testgres_common.py b/tests/test_testgres_common.py
index 37fd2147..7a923b68 100644
--- a/tests/test_testgres_common.py
+++ b/tests/test_testgres_common.py
@@ -2386,7 +2386,7 @@ def test_logical_replication(self, node_svc: PostgresNodeService):
             # create new publication and subscription for specific table
             # (omitting copying data as it's already done)
             pub = node1.publish('newpub', tables=['test'])
-            sub = node2.subscribe(pub, 'newsub', copy_data=False)
+            sub = node2.subscribe(pub, 'newsub', copy_data=False, enabled=True)
 
             node1.safe_psql('insert into test values (4, 4)')
             sub.catchup()