Skip to content

Commit 6ee9c9e

Browse files
committed
dunno
1 parent d791dc7 commit 6ee9c9e

2 files changed

Lines changed: 31 additions & 2 deletions

File tree

lib/plausible/google/ga4/http.ex

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,9 @@ defmodule Plausible.Google.GA4.HTTP do
7777
)
7878

7979
Sentry.Context.set_extra_context(%{ga_response: %{body: body, status: status}})
80-
{:error, :request_failed}
80+
81+
{:error,
82+
{:request_failed, dataset: report_request.dataset, offset: report_request.offset}}
8183

8284
{:error, reason} ->
8385
log_ce_error("retrieving report for #{report_request.dataset}", reason)
@@ -86,7 +88,8 @@ defmodule Plausible.Google.GA4.HTTP do
8688
"[#{inspect(__MODULE__)}:#{report_request.property}] Request failed for #{report_request.dataset}: #{inspect(reason)}"
8789
)
8890

89-
{:error, :request_failed}
91+
{:error,
92+
{:request_failed, dataset: report_request.dataset, offset: report_request.offset}}
9093
end
9194
end
9295

lib/plausible/imported/google_analytics4.ex

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -123,6 +123,32 @@ defmodule Plausible.Imported.GoogleAnalytics4 do
123123

124124
{:error, :rate_limit_exceeded, skip_purge?: true, skip_mark_failed?: true}
125125

126+
{:error, {:request_failed, details}} ->
127+
site_import = Repo.preload(site_import, [:site, :imported_by])
128+
dataset = Keyword.fetch!(details, :dataset)
129+
offset = Keyword.fetch!(details, :offset)
130+
{access_token, refresh_token, token_expires_at} = auth
131+
132+
resume_import_opts = [
133+
property: property,
134+
label: property,
135+
start_date: date_range.first,
136+
end_date: date_range.last,
137+
access_token: access_token,
138+
refresh_token: refresh_token,
139+
token_expires_at: token_expires_at,
140+
resume_from_import_id: site_import.id,
141+
resume_from_dataset: dataset,
142+
resume_from_offset: offset,
143+
job_opts: [schedule_in: {5, :minutes}, unique: nil]
144+
]
145+
146+
new_import(
147+
site_import.site,
148+
site_import.imported_by,
149+
resume_import_opts
150+
)
151+
126152
other ->
127153
other
128154
end

0 commit comments

Comments
 (0)