diff --git a/dbt_automation/operations/flattenjson.py b/dbt_automation/operations/flattenjson.py
index d35f53a..3e9c3d3 100644
--- a/dbt_automation/operations/flattenjson.py
+++ b/dbt_automation/operations/flattenjson.py
@@ -35,8 +35,6 @@ def flattenjson_dbt_sql(
     else:
         dbt_code = f"SELECT {', '.join([quote_columnname(col, warehouse.name) for col in source_columns])}\n"
 
-    # json_columns = warehouse.get_json_columnspec(source_schema, input_name, json_column)
-
     # convert to sql-friendly column names
     sql_columns = make_cleaned_column_names(json_columns_to_copy)
 
diff --git a/dbt_automation/operations/mergeoperations.py b/dbt_automation/operations/mergeoperations.py
index b21e910..7f538ff 100644
--- a/dbt_automation/operations/mergeoperations.py
+++ b/dbt_automation/operations/mergeoperations.py
@@ -113,10 +113,6 @@ def merge_operations_sql(
             op_select_statement, out_cols = casewhen_dbt_sql(
                 operation["config"], warehouse
             )
-        elif operation["type"] == "flattenjson":
-            op_select_statement, out_cols = flattenjson_dbt_sql(
-                operation["config"], warehouse
-            )
         elif operation["type"] == "unionall":
             op_select_statement, out_cols = union_tables_sql(
                 operation["config"], warehouse