From 032bfcd2310c6ade07296b21de724761914b700e Mon Sep 17 00:00:00 2001
From: Maxime Beauchemin <maximebeauchemin@gmail.com>
Date: Fri, 24 Oct 2014 22:05:56 +0000
Subject: [PATCH] Fixing the macros

---
 airflow/macros/__init__.py | 3 +++
 airflow/macros/hive.py     | 8 ++++++++
 2 files changed, 11 insertions(+)
 create mode 100644 airflow/macros/__init__.py
 create mode 100644 airflow/macros/hive.py

diff --git a/airflow/macros/__init__.py b/airflow/macros/__init__.py
new file mode 100644
index 00000000000..78217900b4b
--- /dev/null
+++ b/airflow/macros/__init__.py
@@ -0,0 +1,3 @@
+from random import random
+from datetime import datetime
+import time
diff --git a/airflow/macros/hive.py b/airflow/macros/hive.py
new file mode 100644
index 00000000000..b147316d673
--- /dev/null
+++ b/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)
+