alvaro/lol-analytics
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

requeue matches and players on fail

Browse Source
This commit is contained in:
Álvaro 2024-05-04 01:12:22 +02:00
parent 420b693728
commit 54289237be
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/scrapper/lib/scrapper/processor/match_processor.ex
View File

@ -14,13 +14,13 @@ defmodule Scrapper.Processor.MatchProcessor do
password: "guest", password: "guest",
host: "localhost" host: "localhost"
], ],
on_failure: :reject, on_failure: :reject_and_requeue,
qos: [ qos: [
prefetch_count: 1 prefetch_count: 1
]}, ]},
concurrency: 1, concurrency: 1,
rate_limiting: [ rate_limiting: [
interval: 1000 * 3, interval: 1000 * 1,
allowed_messages: 1 allowed_messages: 1
] ]
], ],

4
apps/scrapper/lib/scrapper/processor/player_processor.ex
View File

@ -15,7 +15,7 @@ defmodule Scrapper.Processor.PlayerProcessor do
password: "guest", password: "guest",
host: "localhost" host: "localhost"
], ],
on_failure: :reject, on_failure: :reject_and_requeue,
qos: [ qos: [
prefetch_count: 1 prefetch_count: 1
]}, ]},
@ -46,7 +46,7 @@ defmodule Scrapper.Processor.PlayerProcessor do
player -> player ->
player player
|> LolAnalytics.Player.PlayerRepo.update_player(%{ |> LolAnalytics.Player.PlayerRepo.update_player(%{
:last_processed_at => DateTime.utc_now() |> DateTime.truncate(:seconds) :last_processed_at => DateTime.utc_now() |> DateTime.truncate(:second)
}) })
end end