Method make_mwm_operator

tools/python/airmaps/dags/build_maps.py:121–128

(self, country)

        storage.wd_publish(env.paths.mwm_path, f"{storage_path}/{env.mwm_version}/")

    def make_mwm_operator(self, country):
        normalized_name = "__".join(country.lower().split())
        return PythonOperator(
            task_id=f"Build_country_{normalized_name}_task",
            provide_context=True,
            python_callable=MapsGenerationDAG.make_build_mwm_func(country),
            dag=self,
        )


PARAMS = {"storage": {"subdir": "open_source"}}