diff --git a/dags/discord_guild_analyzer_etl.py b/dags/discord_guild_analyzer_etl.py index 403996be..147658b5 100644 --- a/dags/discord_guild_analyzer_etl.py +++ b/dags/discord_guild_analyzer_etl.py @@ -17,6 +17,7 @@ DiscordTransformRawMembers, ) from analyzer_helper.discord.fetch_discord_platforms import FetchDiscordPlatforms +from dateutil.parser import parse with DAG( dag_id="discord_guild_analyzer_etl", @@ -63,7 +64,7 @@ def fetch_discord_platforms(**kwargs) -> dict[str, str | datetime | bool]: platform = { "recompute": recompute, "platform_id": platform_id, - "period": period, + "period": parse(period), "guild_id": guild_id, }