)      assert {:ok, %{"subscribed" => topic}} =              run_subscription(                @query,                Schema,                variables: %{"clientId" => client_id},                context: %{pubsub: PubSub}              )      assert_receive {[:absinthe, :execute, :operation, :st