Assign metadata_kv_store_class in enrichment_plugin_scheduler's celer…

…y_beat_service_started method.

yahoo_panoptes/enrichment/enrichment_plugin_scheduler.py

@@ -246,6 +246,7 @@ def celery_beat_service_started(sender=None, args=None, **kwargs):
     """
     global enrichment_plugin_scheduler
     sender.scheduler.panoptes_context = panoptes_context
+    sender.scheduler.metadata_kv_store_class = PanoptesEnrichmentPluginAgentKeyValueStore
     sender.scheduler.task_prefix = const.ENRICHMENT_PLUGIN_SCHEDULER_CELERY_TASK_PREFIX
     enrichment_plugin_scheduler.run(sender, args, **kwargs)