code: def wrap_apply_async(apply_async_func):
      
  
      def call(self, func, args=(), kwds={}, **kwargs):
          wrapped_func = wrap_task_func(func)
          _tracer = execution_context.get_opencensus_tracer()
          propagator = binary_format.BinaryFormatPropagator()
  
          wrapped_kwargs = {}
          wrapped_kwargs["span_context_binary"] = propagator.to_header(
              _tracer.span_context
          )
          wrapped_kwargs["kwds"] = kwds
          wrapped_kwargs["sampler"] = _tracer.sampler
          wrapped_kwargs["exporter"] = _tracer.exporter
          wrapped_kwargs["propagator"] = _tracer.propagator
  
          return apply_async_func(
              self, wrapped_func, args=args, kwds=wrapped_kwargs, **kwargs
          )
  
      return call
docs: Wrap the apply_async function of multiprocessing.pools. Get the function
      that will be called and wrap it then add the opencensus context.