def METHOD_NAME(
    mocked_generate_payload,
    mocked_get_webhooks_for_event,
    mocked_request,
    staff_api_client,
    product_type,
    category,
    permission_manage_products,
    subscription_product_created_webhook,
    settings,
):
    # given
    webhook = subscription_product_created_webhook
    settings.PLUGINS = ["saleor.plugins.webhook.plugin.WebhookPlugin"]
    mocked_get_webhooks_for_event.return_value = [webhook]
    product_type_id = graphene.Node.to_global_id("ProductType", product_type.pk)
    category_id = graphene.Node.to_global_id("Category", category.pk)
    product_name = "test name"
    product_slug = "product-test-slug"
    variables = {
        "input": {
            "productType": product_type_id,
            "category": category_id,
            "name": product_name,
            "slug": product_slug,
        }
    }
    # when
    staff_api_client.post_graphql(
        CREATE_PRODUCT_MUTATION, variables, permissions=[permission_manage_products]
    )
    # then
    mocked_generate_payload.assert_called_once()
    assert mocked_generate_payload.call_args[1]["request"].allow_replica