diff --git a/app/services/ingest/configs/boss.py b/app/services/ingest/configs/boss.py index 0896b1c..86d9818 100644 --- a/app/services/ingest/configs/boss.py +++ b/app/services/ingest/configs/boss.py @@ -105,4 +105,5 @@ register(PlatformConfig( platform="boss", channel="company", data_type="job", table="boss_job", dedup_fields=(DedupFieldSpec(column="job_id", extractor=_extract_job_id),), + push_mapper=_build_boss_push, )) diff --git a/app/services/ingest/configs/qcwy.py b/app/services/ingest/configs/qcwy.py index 891e04c..51ac7b4 100644 --- a/app/services/ingest/configs/qcwy.py +++ b/app/services/ingest/configs/qcwy.py @@ -105,4 +105,5 @@ register(PlatformConfig( DedupFieldSpec(column="job_id", extractor=_extract_job_id), DedupFieldSpec(column="update_date_time", extractor=_extract_update_dt), ), + push_mapper=_build_qcwy_push, )) diff --git a/app/services/ingest/configs/zhilian.py b/app/services/ingest/configs/zhilian.py index 6a85ee8..7e7331c 100644 --- a/app/services/ingest/configs/zhilian.py +++ b/app/services/ingest/configs/zhilian.py @@ -78,4 +78,5 @@ register(PlatformConfig( DedupFieldSpec(column="number", extractor=_extract_number), DedupFieldSpec(column="first_publish_time", extractor=_extract_fpt), ), + push_mapper=_build_zhilian_push, ))