aboutsummaryrefslogtreecommitdiffstats
path: root/src/dataframes.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/dataframes.py')
-rw-r--r--src/dataframes.py14
1 files changed, 6 insertions, 8 deletions
diff --git a/src/dataframes.py b/src/dataframes.py
index d0479f1..94eb509 100644
--- a/src/dataframes.py
+++ b/src/dataframes.py
@@ -71,14 +71,12 @@ def create_fact_purchase_orders(dict_of_df):
def create_fact_payment(dict_of_df):
df_payment = dict_of_df["payment"]
df_payment.index.name = "payment_record_id"
- df_payment["created_date"] = pd.to_datetime(
- df_payment["created_at"]).dt.date
- df_payment["created_time"] = pd.to_datetime(
- df_payment["created_at"]).dt.time
- df_payment["last_updated_date"] = pd.to_datetime(
- df_payment["last_updated"]).dt.date
- df_payment["last_updated_time"] = pd.to_datetime(
- df_payment["last_updated"]).dt.time
+ df_payment["created_date"] = df_payment["created_at"].date()
+ df_payment["created_time"] = df_payment["created_at"].time
+ df_payment["last_updated_date"] = df_payment["last_updated"].date()
+ df_payment["last_updated_time"] = df_payment["last_updated"].time
+ df_payment["payment_date"] = pd.to_datetime(
+ df_payment["payment_date"], format="%Y-%m-%d")
fact_payment = df_payment.loc[
:,
[
git.ajschof.me — hosted by ajschofield — powered by cgit