Commit d4eab218 authored by Heinz N. Gies's avatar Heinz N. Gies

Fix get tid handoffs

parent 035ac1ad
......@@ -45,7 +45,7 @@ start(run,
dflow_span:log("read ~p @ ~p", [Chunk, Start]),
%% We do a bit of cheating here this allows us to loop.
State1 = State#state{start = Start + Chunk, count = Count - Chunk},
case ddb_connection:get(Bucket, Key, Start, Chunk, ottersp:ids()) of
case ddb_connection:get(Bucket, Key, Start, Chunk, ottersp:get_span()) of
{error, _Error} ->
dflow_span:log("read failed"),
{done, State};
......@@ -63,7 +63,7 @@ start(run,
start(run, State = #state{start = Start, count = Count,
bucket = Bucket, key = Key}) ->
dflow_span:log("read ~p @ ~p", [Count, Start]),
case ddb_connection:get(Bucket, Key, Start, Count, ottersp:ids()) of
case ddb_connection:get(Bucket, Key, Start, Count, ottersp:get_span()) of
{error, _Error} ->
dflow_span:log("read failed"),
{done, State};
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment