src/merge/normalize.py

# This script runs both the stock and crypto normalization pipelines from the norm/ directory
import sys
import os

# Add norm directory to sys.path for imports
norm_dir = os.path.join(os.path.dirname(__file__), 'norm')
sys.path.insert(0, norm_dir)

# Import and run stock normalization
try:
    from norm import stocks
    print("\n--- Running Stock Normalization ---")
    stocks.main()
except Exception as e:
    print(f"[ERROR] Stock normalization failed: {e}")

# Import and run crypto normalization
try:
    from norm import crypto
    print("\n--- Running Crypto Normalization ---")
    crypto.main()
except Exception as e:
    print(f"[ERROR] Crypto normalization failed: {e}")