anchor.diff:      {ok, worker_host:plugin_state()} | {error, Reason :: term()}.
   init(_Args) ->
       ?info("[ DBSync ]: Starting dbsync..."),
  -    Since = 0,
  -    state_put(global_resume_seq, Since),
  +    Since = state_get(global_resume_seq),
       timer:send_after(?BROADCAST_STATUS_INTERVAL, whereis(dbsync_worker), {timer, bcast_status}),
       timer:send_after(timer:seconds(5), whereis(dbsync_worker), {sync_timer, {async_init_stream, Since, infinity, global}}),
       timer:send_after(?FLUSH_QUEUE_INTERVAL, whereis(dbsync_worker), {timer, {flush_queue, global}}),
  
positive.code:                     ?error("Unable to find space id for document ~p due to: ~p", [Doc, Reason]),
                      {error, Reason}
              end,
  %%            queue_update_until(QueueKey, Seq),
              Ans;
          {true, true} ->
              ?info("Rereplication detected, skipping ~p", [Doc]),
  
negative.code:                     ?info("[ DBSync ] Flush loop is too fast, breaking this one."),
                      throw({too_many_flush_loops, {flush_queue, QueueKey}});
                  _ ->
                      dbsync_utils:temp_put(last_global_flush, CTime, 0),
                      ensure_global_stream_active()
              end;
          _ -> ok
      end,
  