def update_input_refcounts(self):

    def real_producer(pv):
      real = pv.producer
      while real.parts:
        real = real.parts[-1]
      return real

    if not self.is_composite():
      for main_input in self.inputs:
        if not isinstance(main_input, pvalue.PBegin):
          real_producer(main_input).refcounts[main_input.tag] += 1
      for side_input in self.side_inputs:
        real_producer(side_input).refcounts[side_input.tag] += 1
Establish that if we get a string value, we do a lookup against
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/pipeline.py/AppliedPTransform.update_input_refcounts--crossover with--dataset/ETHPy150Open ansible/tower-cli/tests/test_utils_types.py/RelatedTests.test_convert_by_lookup