template: sync giter8 example pipelines and tooling

Author: vim89

flowforge.g8/README.md

@@ -45,9 +45,6 @@ This template ships with a starter CI at `.github/workflows/ci.yml`.
 ### 6. Switch to Deequ (optional)
 Set `-Dff.quality.mode=deequ` to use Deequ for DQ; otherwise native Spark checks are used.
 
-### Notes
-- Template avoids `$` in source files to prevent giter8 escaping problems.
-
 ## What you just proved
 
 🎯 **flowforge's Core USP**: "Data pipelines will not even build if source or target schema do not match or align!"
@@ -81,4 +78,4 @@ flowforge supports 5 schema evolution policies:
 - [GitHub Issues](https://github.com/flowforge/flowforge/issues)
 
 ---
-*Generated with flowforge Giter8 Template | 100% Compile-Time Contracts*
+*Generated with flowforge giter8 template | 100% compile-time contracts*

flowforge.g8/src/main/g8/.github/workflows/ci.yml

@@ -25,18 +25,18 @@ jobs:
         uses: actions/cache@v4
         with:
           path: ~/.ivy2/cache
-          key: ${{ runner.os }}-ivy2-${{ hashFiles('**/build.sbt') }}
+          key: \${{ runner.os }}-ivy2-\${{ hashFiles('**/build.sbt') }}
           restore-keys: |
-            ${{ runner.os }}-ivy2-
+            \${{ runner.os }}-ivy2-
 
       - name: sbt format check
         run: sbt -v scalafmtSbtCheck scalafmtCheckAll
 
   build:
     runs-on: ubuntu-latest
-    if: ${{ env.RUN_FULL == 'true' }}
+    if: \${{ env.RUN_FULL == 'true' }}
     env:
-      RUN_FULL: ${{ vars.RUN_FULL }}
+      RUN_FULL: \${{ vars.RUN_FULL }}
     steps:
       - name: Checkout
         uses: actions/checkout@v4
@@ -50,9 +50,9 @@ jobs:
         uses: actions/cache@v4
         with:
           path: ~/.ivy2/cache
-          key: ${{ runner.os }}-ivy2-${{ hashFiles('**/build.sbt') }}
+          key: \${{ runner.os }}-ivy2-\${{ hashFiles('**/build.sbt') }}
           restore-keys: |
-            ${{ runner.os }}-ivy2-
+            \${{ runner.os }}-ivy2-
       - name: Compile
         run: sbt -v compile
       - name: Test

flowforge.g8/src/main/g8/Makefile

@@ -5,7 +5,7 @@
 
 # Default target
 help:
-	@echo "FlowForge Pipeline"
+	@echo "flowforge pipeline"
 	@echo "================================="
 	@echo "Available commands:"
 	@echo ""
@@ -25,7 +25,7 @@ build:
 	@echo "🔨 Building FlowForge pipeline..."
 	sbt compile
 
-test: 
+test:
 	@echo "🧪 Running tests..."
 	sbt test
 
@@ -56,7 +56,7 @@ demo-contract-drift:
 	@make build
 	@echo ""
 	@echo "2. Now edit Contract.scala and change 'id: Long' to 'id: String'"
-	@echo "3. Run 'make build' again to see compile failure"  
+	@echo "3. Run 'make build' again to see compile failure"
 	@echo "4. Revert the change to fix compilation"
 	@echo ""
-	@echo "This proves FlowForge's core USP: Pipelines won't build if contracts drift!"
+	@echo "This proves flowforge's core USP: Pipelines won't build if contracts drift!"

flowforge.g8/src/main/g8/README.md

@@ -1,6 +1,6 @@
 # $name$
 
-Generated with FlowForge.g8. Minimal template; only `name` and `organization` are substituted.
+Generated with flowforge.g8. Minimal template; only `name` and `organization` are substituted.
 
 Build
 ```bash
@@ -13,6 +13,5 @@ sbt run
 ```
 
 Notes
-- Template avoids `$` in code to prevent escaping issues.
 - Customize package and code under `src/main/scala/com/flowforge/example`.
 

flowforge.g8/src/main/g8/build.sbt

@@ -62,3 +62,5 @@ lazy val root = (project in file("."))
     ),
     libraryDependencies ++= ffDeps ++ sparkDeps ++ loggingDeps ++ jdbcDeps ++ zioDeps ++ testDeps,
   )
+
+// TODO: Not compiling, check & fix

flowforge.g8/src/main/g8/ops/marquez/Makefile

@@ -27,14 +27,14 @@ lineage-logs:
 
 # Check status of lineage services
 lineage-status:
-	@echo "FlowForge Lineage Stack Status:"
+	@echo "flowforge lineage stack status:"
 	@echo "================================"
 	docker compose -f docker-compose.yml ps
 	@echo ""
 	@echo "Service Health Checks:"
-	@echo "• PostgreSQL: $$(curl -s -o /dev/null -w '%{http_code}' http://localhost:5432 2>/dev/null || echo 'DOWN')"
-	@echo "• Marquez API: $$(curl -s -o /dev/null -w '%{http_code}' http://localhost:5000/api/v1/namespaces 2>/dev/null || echo 'DOWN')"
-	@echo "• Marquez Web: $$(curl -s -o /dev/null -w '%{http_code}' http://localhost:3000 2>/dev/null || echo 'DOWN')"
+	@echo "• PostgreSQL: \$(curl -s -o /dev/null -w \'%{http_code}\' http://localhost:5432 2>/dev/null || echo \'DOWN\')"
+	@echo "• Marquez API: \$(curl -s -o /dev/null -w \'%{http_code}\' http://localhost:5000/api/v1/namespaces 2>/dev/null || echo \'DOWN\')"
+	@echo "• Marquez Web: \$(curl -s -o /dev/null -w \'%{http_code}\' http://localhost:3000 2>/dev/null || echo \'DOWN\')"
 
 # Clean up all data (removes PostgreSQL volume)
 lineage-clean:
@@ -48,7 +48,7 @@ lineage-reset: lineage-clean lineage-up
 	@echo "✓ Lineage stack reset complete"
 
 help:
-	@echo "FlowForge Lineage Management Commands:"
+	@echo "flowforge lineage management commands:"
 	@echo "====================================="
 	@echo "  make lineage-up     - Start the lineage stack"
 	@echo "  make lineage-down   - Stop the lineage stack"
@@ -57,5 +57,5 @@ help:
 	@echo "  make lineage-clean  - Clean up all data"
 	@echo "  make lineage-reset  - Reset (clean + restart)"
 	@echo ""
-	@echo "After starting, run your FlowForge pipelines and view lineage at:"
+	@echo "After starting, run your flowforge pipelines and view lineage at:"
 	@echo "http://localhost:3000"

flowforge.g8/src/main/g8/src/main/scala/com/flowforge/app/PipelineApp.scala

@@ -106,7 +106,7 @@ object PipelineApp extends IOApp.Simple {
           QualityConstraint.NullRateBelow(RefinedTypes.FieldName.unsafeFrom("email"), 0.0),
           QualityConstraint.Pattern(
             RefinedTypes.FieldName.unsafeFrom("email"),
-            "^[A-Za-z0-9+_.-]+@[A-Za-z0-9.-]+\\.[A-Za-z]{2,}",
+            "^[A-Za-z0-9+_.-]+@[A-Za-z0-9.-]+\\\\.[A-Za-z]{2,}",
           ),
           QualityConstraint.Min(RefinedTypes.FieldName.unsafeFrom("age"), 0.0),
           QualityConstraint.Max(RefinedTypes.FieldName.unsafeFrom("age"), 120.0),

flowforge.g8/src/main/g8/src/main/scala/com/flowforge/example/Hello.scala

@@ -2,7 +2,7 @@ package com.flowforge.example
 
 object Hello {
   def main(args: Array[String]): Unit = {
-    val msg = "Hello, FlowForge! " + "This project was generated by giter8."
+    val msg = "Hello, flowforge! " + "This project was generated by giter8."
     println(msg)
   }
 }

flowforge.g8/src/main/g8/src/main/scala/com/flowforge/sample/DemoPipeline.scala

@@ -6,6 +6,6 @@ package com.flowforge.sample
  */
 object DemoPipeline {
   def main(args: Array[String]): Unit = {
-    println("DemoPipeline: add FlowForge libs and your pipeline when ready.")
+    println("DemoPipeline: add flowforge libs and your pipeline when ready.")
   }
 }