33 lines
1.0 KiB
Python
33 lines
1.0 KiB
Python
# main.py
|
|
from src.pipeline.unified_stream import load_and_merge
|
|
from src.pipeline.relative_date_trigger import apply_birthday_recursion
|
|
from src.pipeline.rf_scoring import calculate_rf_score
|
|
from src.pipeline.list_hygiene import apply_list_hygiene
|
|
from src.pipeline.ethics_flags import apply_ethics_checks
|
|
from src.pipeline.deliverability_check import run_deliverability_check
|
|
|
|
from src.models.engagement_scoring import calculate_engagement_scores
|
|
from src.models.churn_classifier import classify_churn
|
|
from src.models.send_time_optimizer import optimize_send_time
|
|
from src.models.predictive_segments import build_predictive_segments
|
|
|
|
print("=== WEEK 2 PIPELINE START ===")
|
|
df= load_and_merge()
|
|
apply_birthday_recursion()
|
|
calculate_rf_score()
|
|
apply_list_hygiene()
|
|
|
|
apply_ethics_checks()
|
|
run_deliverability_check()
|
|
|
|
print("=== WEEK 2 PIPELINE COMPLETE ===")
|
|
|
|
print("=== WEEK 3 START ===")
|
|
|
|
df = calculate_engagement_scores(df)
|
|
df = classify_churn(df)
|
|
df = optimize_send_time(df)
|
|
df=build_predictive_segments(df)
|
|
|
|
print("=== WEEK 3 COMPLETE ===")
|