yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: fix some expressions after refactoring

This commit is contained in:
Thales Macedo Garitezi 2023-01-12 16:07:25 -03:00
parent fecdbac9a8
commit 4cb83d0c9a
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/emqx_resource/src/emqx_resource_worker.erl
View File

@ -293,6 +293,7 @@ pick_cast(Id, Key, Query) ->
end). end).
resume_from_blocked(Data) -> resume_from_blocked(Data) ->
#{inflight_tid := InflightTID} = Data,
case inflight_get_first(InflightTID) of case inflight_get_first(InflightTID) of
empty -> empty ->
retry_queue(Data); retry_queue(Data);
@ -389,8 +390,12 @@ retry_queue(
end. end.
retry_inflight_sync(Ref, QueryOrBatch, Data0) -> retry_inflight_sync(Ref, QueryOrBatch, Data0) ->
#{id := Id, inflight_tid := InflightTID, index := Index, resume_interval := ResumeT} = #{
Data0 id := Id,
inflight_tid := InflightTID,
index := Index,
resume_interval := ResumeT
} = Data0,
QueryOpts = #{}, QueryOpts = #{},
%% if we are retrying an inflight query, it has been sent %% if we are retrying an inflight query, it has been sent
HasBeenSent = true, HasBeenSent = true,