def process_noncurrent_mode(orig_date, line, random_delays):
    epoch = datetime.datetime(1970, 1, 1)
    ts_int = int(
        ((orig_date - epoch).total_seconds() * 1000) +
        orig_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))
Called when not using --current flag; retaining original time
dataset/ETHPy150Open GoogleCloudPlatform/cloud-pubsub-samples-python/gce-cmdline-publisher/traffic_pubsub_generator.py/process_noncurrent_mode