Druid hotfix. (#1710)

This commit is contained in:
Bogdan 2016-11-29 18:11:59 -05:00 committed by GitHub
parent 0be02e67a5
commit 65e92327ab

View File

@ -2151,7 +2151,7 @@ class DruidDatasource(Model, AuditMixinNullable, Queryable):
tzinfo=config.get("DRUID_TZ"))
return dt + timedelta(milliseconds=time_offset)
if DTTM_ALIAS in df.columns and time_offset:
df.timestamp = df.timestamp.apply(increment_timestamp)
df[DTTM_ALIAS] = df[DTTM_ALIAS].apply(increment_timestamp)
return QueryResult(
df=df,