Skip to content

Commit b70114e

Browse files
ttt161ttt161
andauthored
bump progressor-1.0.15 (#189)
* bump progressor-1.0.15 * fix context decoding * fix for dialyzer --------- Co-authored-by: ttt161 <losto@nix>
1 parent c296a6b commit b70114e

3 files changed

Lines changed: 9 additions & 4 deletions

File tree

apps/hg_progressor/src/hg_progressor.erl

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ cleanup() ->
120120
-spec process({task_t(), encoded_args(), process()}, hg_woody_service_wrapper:handler_opts(), encoded_ctx()) ->
121121
process_result().
122122
process({CallType, BinArgs, Process}, #{ns := NS} = Options, BinCtx) ->
123-
{WoodyContext0, OtelCtx} = woody_rpc_helper:decode_rpc_context(marshal(term, BinCtx)),
123+
{WoodyContext0, OtelCtx} = decode_rpc_context(BinCtx),
124124
ok = woody_rpc_helper:attach_otel_context(OtelCtx),
125125
#{last_event_id := LastEventID} = Process,
126126
Machine = marshal(process, Process#{ns => NS}),
@@ -136,6 +136,11 @@ process({CallType, BinArgs, Process}, #{ns := NS} = Options, BinCtx) ->
136136

137137
%% Internal functions
138138

139+
decode_rpc_context(<<>>) ->
140+
woody_rpc_helper:decode_rpc_context(#{});
141+
decode_rpc_context(BinCtx) ->
142+
woody_rpc_helper:decode_rpc_context(marshal(term, BinCtx)).
143+
139144
handle_result(
140145
#mg_stateproc_SignalResult{
141146
change = #'mg_stateproc_MachineStateChange'{

rebar.config

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242
{fault_detector_proto, {git, "https://github.com/valitydev/fault-detector-proto.git", {branch, "master"}}},
4343
{limiter_proto, {git, "https://github.com/valitydev/limiter-proto.git", {tag, "v2.1.0"}}},
4444
{herd, {git, "https://github.com/wgnet/herd.git", {tag, "1.3.4"}}},
45-
{progressor, {git, "https://github.com/valitydev/progressor.git", {tag, "v1.0.12"}}},
45+
{progressor, {git, "https://github.com/valitydev/progressor.git", {tag, "v1.0.15"}}},
4646
{prometheus, "4.11.0"},
4747
{prometheus_cowboy, "0.1.9"},
4848

rebar.lock

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
0},
3636
{<<"epg_connector">>,
3737
{git,"https://github.com/valitydev/epg_connector.git",
38-
{ref,"2e86da8083908d0d35a4eed3e2168c9ba6a8d04a"}},
38+
{ref,"af35200fa1c63e7afeaa90cad862944c194b2686"}},
3939
1},
4040
{<<"epgsql">>,
4141
{git,"https://github.com/epgsql/epgsql.git",
@@ -100,7 +100,7 @@
100100
0},
101101
{<<"progressor">>,
102102
{git,"https://github.com/valitydev/progressor.git",
103-
{ref,"ed7e39698f024c87e5bfc604fe26eefcda0d6b01"}},
103+
{ref,"fdebffd0db07208faa452e0151491769949a5076"}},
104104
0},
105105
{<<"prometheus">>,{pkg,<<"prometheus">>,<<"4.11.0">>},0},
106106
{<<"prometheus_cowboy">>,{pkg,<<"prometheus_cowboy">>,<<"0.1.9">>},0},

0 commit comments

Comments
 (0)