From 9ae6038ce13483273555d3b59f112ec416418687 Mon Sep 17 00:00:00 2001 From: Argenis Leon Date: Fri, 15 Nov 2019 11:00:29 -0600 Subject: [PATCH] Fix metadata handling --- optimus/io/jdbc.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/optimus/io/jdbc.py b/optimus/io/jdbc.py index 8e308e4e..b91ec0e0 100644 --- a/optimus/io/jdbc.py +++ b/optimus/io/jdbc.py @@ -128,6 +128,9 @@ def table_to_df(self, table_name, columns="*", limit=None): # Bring the data to local machine if not every time we call an action is going to be # retrieved from the remote server df = df.run() + df.set_meta("file_name", table_name) + df.reset() + return df def execute(self, query, limit=None):