fix(zebra): add ff for cachehub protection (#486)

## 📝 Description

renderedtext/project-tasks#2647

## ✅ Checklist
- [x] I have tested this change
- [ ] This change requires documentation update

Author: VeljkoMaksimovic

zebra/lib/zebra/workers/job_request_factory.ex

@@ -72,7 +72,7 @@ defmodule Zebra.Workers.JobRequestFactory do
            Task.async(fn ->
              if Job.self_hosted?(job.machine_type),
                do: {:ok, nil},
-               else: Cache.find(project.cache_id, repo_proxy)
+               else: Cache.find(project.cache_id, repo_proxy, org_id)
            end),
          find_secrets <-
            Task.async(fn -> Secrets.load(org_id, job.id, spec, project, repo_proxy) end),

zebra/lib/zebra/workers/job_request_factory/cache.ex

@@ -13,19 +13,21 @@ defmodule Zebra.Workers.JobRequestFactory.Cache do
   # Overall, if cache system is down, we ignore every issue.
   #
 
-  def find(nil, _repo_proxy) do
+  def find(nil, _repo_proxy, _org_id) do
     # We don't fail any jobs due to a missing cache connection,
     # but we should make sure we are aware of any issues in this area.
     Watchman.increment("external.cachehub.describe.failed")
 
     {:ok, nil}
   end
 
-  def find(cache_id, repo_proxy) do
+  def find(cache_id, repo_proxy, org_id) do
     Watchman.benchmark("external.cachehub.describe", fn ->
       req = Request.new(cache_id: cache_id)
 
-      with false <- forked_pr?(repo_proxy),
+      with false <-
+             forked_pr?(repo_proxy) and
+               FeatureProvider.feature_enabled?(:disable_forked_pr_cache, param: org_id),
            {:ok, endpoint} <- Application.fetch_env(:zebra, :cachehub_api_endpoint),
            {:ok, channel} <- GRPC.Stub.connect(endpoint),
            {:ok, response} <- Stub.describe(channel, req, timeout: 30_000) do
@@ -40,7 +42,10 @@ defmodule Zebra.Workers.JobRequestFactory.Cache do
         end
       else
         true ->
-          Logger.info("Skipping fetching of the cache as the job is part of Forked PR build.")
+          Logger.info(
+            "Skipping fetching of the cache as the job is part of Forked PR build. Cache id #{inspect(cache_id)}"
+          )
+
           {:ok, nil}
 
         e ->