anchor.diff:  
       DocsSet = trunc(ThreadsNum/ConflictedThreads),
       spawn_at_nodes(Workers, ThreadsNum, DocsSet, TestFun),
  -    OpsOkNum = ThreadsNum * DocsPerThead,
  -    OpsNum = OpsOkNum * OpsPerDoc,
  +    OpsNum = ThreadsNum * DocsPerThead * OpsPerDoc,
       {OkNum, OkTime, ErrorNum, ErrorTime} = count_answers(OpsNum),
       ?assertEqual(OpsNum, OkNum+ErrorNum),
  -    ?assertEqual(OpsOkNum, OkNum),
  +    % TODO change when datastore behavior will be coherent
  +    ct:print("Create ok num: ~p", [OkNum]),
  +    ?assert((ThreadsNum * DocsPerThead >= OkNum) and (DocsPerThead * DocsSet =< OkNum)),
   
       TestFun2 = fun(DocsSet) ->
           for(1, DocsPerThead, fun(I) ->
  
positive.code: 
      DocsSet = trunc(ThreadsNum/ConflictedThreads),
      spawn_at_nodes(Workers, ThreadsNum, DocsSet, TestFun),
      OpsOkNum = ThreadsNum * DocsPerThead,
      OpsNum = OpsOkNum * OpsPerDoc,
      {OkNum, OkTime, ErrorNum, _ErrorTime} = count_answers(OpsNum),
      ?assertEqual(OpsNum, OkNum),
      ?assertEqual(0, ErrorNum),
  
negative.code: 
      DocsSet = trunc(ThreadsNum/ConflictedThreads),
      spawn_at_nodes(Workers, ThreadsNum, DocsSet, TestFun),
      OpsNum = ThreadsNum * DocsPerThead * OpsPerDoc,
      {OkNum, OkTime, ErrorNum, _ErrorTime} = count_answers(OpsNum),
      ?assertEqual(OpsNum, OkNum),
      ?assertEqual(0, ErrorNum),
  