def process_current_mode(orig_date, diff, line, replay, random_delays):
    epoch = datetime.datetime(1970, 1, 1)
    if replay:  # use adjusted date from line of data
        new_date = orig_date + diff
        line[0] = new_date.strftime("%Y-%m-%d %H:%M:%S")
        ts_int = int(
            ((new_date - epoch).total_seconds() * 1000) +
            new_date.microsecond/1000)
        # 'random_delays' indicates whether to include random apparent delays
        # in published data
        if random_delays:
            (line, ts_int) = maybe_add_delay(line, ts_int)
        return (line, str(ts_int))
    else:  # simply using current time
        currtime = datetime.datetime.utcnow()
        ts_int = int(
            ((currtime - epoch).total_seconds() * 1000) +
            currtime.microsecond/1000)
        line[0] = currtime.strftime("%Y-%m-%d %H:%M:%S")
        # 'random_delays' indicates whether to include random apparent delays
        # in published data
        if random_delays:
            (line, ts_int) = maybe_add_delay(line, ts_int)
        return (line, str(ts_int))
When using --current flag, modify original data to generate updated time
dataset/ETHPy150Open GoogleCloudPlatform/cloud-pubsub-samples-python/gce-cmdline-publisher/traffic_pubsub_generator.py/process_current_mode