diff --git a/src/lake_fs.py b/src/lake_fs.py
index b5ee70a..1b3dcf1 100644
--- a/src/lake_fs.py
+++ b/src/lake_fs.py
@@ -9,6 +9,25 @@
 import uuid
 import sys
 
+def execute_command(command):
+        try:
+            result = subprocess.run(command, check=True, capture_output=True, text=True)
+            logging.info("Command output: %s", result.stdout)
+            return result
+        except subprocess.CalledProcessError as e:
+            logging.error("Error executing command: %s", e.stderr)
+            return e
+        
+def lakefs_merge_into_main():
+        logging.info("Uploading files from data directory to branch...")
+        command = [
+            "lakectl", "merge",
+            f"lakefs://example-repo/ingestion/",
+            f"lakefs://example-repo/main/",
+            "-m", "Merge ingestion branch into main"
+        ]
+        execute_command(command)
+
 class LakeFSManager:
     def __init__(self, repo_name):
         self.client = Client()