diff --git a/src/main/scala/Main.scala b/src/main/scala/Main.scala
index c793f43..d8045d1 100644
--- a/src/main/scala/Main.scala
+++ b/src/main/scala/Main.scala
@@ -18,7 +18,12 @@ object Main extends IOApp {
       dataService <- DataService.of
       fetchService <- FetchService.of
 
-      fetchCsvList = new FileNameService().generateCurrentHour.flatMap(fetchService.fetchSingleFile)
+      fetchCsvList = new FileNameService().generateCurrentHour
+        .flatMap(fetchService.fetchSingleFile)
+        .flatMap {
+          case Right((name, content)) => postgresService.save(name, content)
+          case Left(error) => IO.raiseError(error)
+        }
       fetchCsvTask = scheduler.scheduleTask("Fetch CSV", List(31), fetchCsvList).compile.drain
 
       cleanupTask = scheduler.scheduleTask("Cleanup", List(1), dataService.deleteOldForecasts()).compile.drain