Fixing the macros

airflow/macros/__init__.py

@@ -0,0 +1,3 @@
+from random import random
+from datetime import datetime
+import time

airflow/macros/hive.py

@@ -0,0 +1,8 @@
+from airflow import settings
+from airflow.hooks.hive_hook import HiveHook
+
+def max_partition(
+        table, schema="default", hive_dbid=settings.HIVE_DEFAULT_DBID):
+    hh = HiveHook(hive_dbid=hive_dbid)
+    return hh.max_partition(schema=schema, table=table)
+