anchor.diff:  
   
   %% @private
  --spec add_oneclient_annotations_if_necessary(json_utils:json_map(), initiation_ctx()) ->
  +-spec add_function_ctx_annotations(json_utils:json_map(), initiation_ctx()) ->
       json_utils:json_map().
  -add_oneclient_annotations_if_necessary(FunctionDefinition, #initiation_ctx{
  +add_function_ctx_annotations(FunctionDefinition, #initiation_ctx{
  +    task_executor_initiation_ctx = #atm_task_executor_initiation_ctx{
  +        workflow_execution_ctx = AtmWorkflowExecutionCtx,
  +        task_execution_id = AtmTaskExecutionId
  +    },
  +    executor = #atm_openfaas_task_executor{function_name = FunctionName}
  +}) ->
  +    AtmWorkflowExecutionId = atm_workflow_execution_ctx:get_workflow_execution_id(
  +        AtmWorkflowExecutionCtx
  +    ),
  +    update_function_annotations(FunctionDefinition, #{
  +        <<"function.openfaas.onedata.org/workflow_execution_id">> => AtmWorkflowExecutionId,
  +        <<"function.openfaas.onedata.org/task_execution_id">> => AtmTaskExecutionId,
  +        %% TODO ŁO change to function_name? would require changes to current pod status collector
  +        <<"function.openfaas.onedata.org/name">> => FunctionName
  +    }).
  +
  +
  +%% @private
  +-spec add_data_stream_annotations_if_required(json_utils:json_map(), initiation_ctx()) ->
  +    json_utils:json_map().
  +add_data_stream_annotations_if_required(FunctionDefinition, #initiation_ctx{
  +    task_executor_initiation_ctx = #atm_task_executor_initiation_ctx{
  +        supplementary_results = []
  +    }
  +}) ->
  +    FunctionDefinition;
  +
  +add_data_stream_annotations_if_required(FunctionDefinition, #initiation_ctx{
  +    task_executor_initiation_ctx = #atm_task_executor_initiation_ctx{
  +        supplementary_results = AtmTaskExecutionSupplementaryResultNames
  +    }
  +}) ->
  +    update_function_annotations(FunctionDefinition, #{
  +        <<"data_stream.openfaas.onedata.org/inject">> => <<"enabled">>,
  +        <<"data_stream.openfaas.onedata.org/names">> => AtmTaskExecutionSupplementaryResultNames
  +    }).
  +
  +
  +%% @private
  +-spec add_oneclient_annotations_if_required(json_utils:json_map(), initiation_ctx()) ->
  +    json_utils:json_map().
  +add_oneclient_annotations_if_required(FunctionDefinition, #initiation_ctx{
       executor = #atm_openfaas_task_executor{operation_spec = #atm_openfaas_operation_spec{
           docker_execution_options = #atm_docker_execution_options{mount_oneclient = false}
       }}}
   ) ->
       FunctionDefinition;
  -add_oneclient_annotations_if_necessary(FunctionDefinition, #initiation_ctx{
  +
  +add_oneclient_annotations_if_required(FunctionDefinition, #initiation_ctx{
       task_executor_initiation_ctx = #atm_task_executor_initiation_ctx{
           workflow_execution_ctx = AtmWorkflowExecutionCtx
       },
  
positive.code:             true -> tokens:confine(AccessToken, #cv_data_readonly{});
              false -> AccessToken
          end
      },
  
      maps:update_with(<<"annotations">>, fun(Annotations) ->
          json_utils:merge([Annotations, OneclientMountRelatedAnnotations])
      end, OneclientMountRelatedAnnotations, FunctionDefinition).
  
  
  %% @private
  
negative.code:     },
      FullDefinition1 = add_default_properties(BaseDefinition),
      FullDefinition2 = add_resources_properties(FullDefinition1, InitiationCtx),
      FullDefinition3 = add_function_ctx_annotations(FullDefinition2, InitiationCtx),
      FullDefinition4 = add_data_stream_annotations_if_required(FullDefinition3, InitiationCtx),
      add_oneclient_annotations_if_required(FullDefinition4, InitiationCtx).
  
  
  %% @private
  