import apache_beam as beam

def join_dict(ident, source):
    return {**ident, **source}


with beam.Pipeline() as pipeline:
  icon_pairs = (
          pipeline | 'Create icons' >> beam.Create([
      {'ident': 'uid2429', 'user_id': '7d1bb900-e491-11ea-8aa1-e86a64ff713e', 'is_exist': 1}])
  | 'key_source' >> beam.Map(lambda dept: (dept['ident'], dept))
  )

  duration_pairs = (pipeline | 'Create durations' >> beam.Create([
      {'an': 'cleanmypc', 'ea': 'ea3', 'ec': 'ec4', 'ev': None, 'ident': 'uid2429'}])
  | 'key_user' >> beam.Map(lambda dept: (dept['ident'], dept))
                    )

  merge_pipeline = (duration_pairs
                    | 'MergeDict' >> beam.Map(join_dict,  beam.pvalue.AsDict(icon_pairs))
                    )