diff --git a/cmd/pg-pubsub-demo/main.go b/cmd/pg-pubsub-demo/main.go index 744348d..2ade756 100644 --- a/cmd/pg-pubsub-demo/main.go +++ b/cmd/pg-pubsub-demo/main.go @@ -32,7 +32,6 @@ func run(ctx context.Context) error { return with.PSQL(ctx, *c, func(pg *sql.DB) error { log.Println("setup...") if _, err := pg.ExecContext(ctx, ` - DROP SCHEMA IF EXISTS "pubsub" CASCADE; CREATE SCHEMA IF NOT EXISTS "pubsub"; CREATE TABLE IF NOT EXISTS "pubsub".topic (