def METHOD_NAME(self):
    """Tests the pipeline by creating mock data and invoking respective transforms"""
    with TestPipeline() as pipeline:
        sideinput_filepath = (
            pipeline | 'Read side Input file path' >> beam.Create(
                ["gs://bucketname/input/sideinput/20200503".encode()]) |
            "Add Timestamp" >> beam.Map(
                lambda e: beam.window.TimestampedValue(e, int(time.time())))
        )
        sideinput_collections = main.get_sideinput_collections(
            sideinput_filepath, static_data.ReadStaticSideInput())
        sales_events = (
            pipeline | 'Read primary events' >> beam.Create(
                static_data.get_maininput_events()) |
            'Attach timestamp' >> beam.Map(
                lambda e: beam.window.TimestampedValue(e, int(time.time())))
            | "Add Fixed window" >> beam.WindowInto(
                beam.window.FixedWindows(10)))
        enriched_events = main.get_enriched_events(sales_events,
                                                   sideinput_collections)
        results = enriched_events | "UnPack the events" >> beam.FlatMap(
            lambda x: x)
        assert_that(results,
                    equal_to(static_data.get_expected_enriched_events()))