in 04_streaming/transform/df04.py [0:0]
def add_24h_if_before(arrtime, deptime):
import datetime
if len(arrtime) > 0 and len(deptime) > 0 and arrtime < deptime:
adt = datetime.datetime.strptime(arrtime, '%Y-%m-%d %H:%M:%S')
adt += datetime.timedelta(hours=24)
return adt.strftime('%Y-%m-%d %H:%M:%S')
else:
return arrtime