From 2ef36c8c77bcec0b92906896e7e89b67106a49ae Mon Sep 17 00:00:00 2001 From: Sapan Bhatia Date: Mon, 2 Sep 2013 14:30:37 -0400 Subject: [PATCH] Schedules for various steps --- planetstack/observer/steps/sync_external_routes.py | 2 ++ planetstack/observer/steps/sync_network_slivers.py | 2 +- planetstack/observer/steps/sync_networks.py | 1 + planetstack/observer/steps/sync_site_privileges.py | 2 ++ planetstack/observer/steps/sync_sites.py | 1 + planetstack/observer/steps/sync_slice_memberships.py | 1 + planetstack/observer/steps/sync_slices.py | 1 + planetstack/observer/steps/sync_sliver_ips.py | 1 + planetstack/observer/steps/sync_slivers.py | 1 + planetstack/observer/steps/sync_users.py | 1 + 10 files changed, 12 insertions(+), 1 deletion(-) diff --git a/planetstack/observer/steps/sync_external_routes.py b/planetstack/observer/steps/sync_external_routes.py index ba4f939..fda66bd 100644 --- a/planetstack/observer/steps/sync_external_routes.py +++ b/planetstack/observer/steps/sync_external_routes.py @@ -4,6 +4,8 @@ from planetstack.config import Config class SyncExternalRoutes(SyncStep): # XXX what does this provide? + requested_interval = 86400 # This step is slow like a pig. Let's run it infrequently + def call(self): routes = self.manager.driver.get_external_routes() subnets = self.manager.driver.shell.quantum.list_subnets()['subnets'] diff --git a/planetstack/observer/steps/sync_network_slivers.py b/planetstack/observer/steps/sync_network_slivers.py index 414a260..3870924 100644 --- a/planetstack/observer/steps/sync_network_slivers.py +++ b/planetstack/observer/steps/sync_network_slivers.py @@ -3,7 +3,7 @@ import base64 from planetstack.config import Config class SyncNetworkSlivers(OpenStackSyncStep): - slow=True + requested_interval = 3600 provides=[NetworkSliver] def call(self): diff --git a/planetstack/observer/steps/sync_networks.py b/planetstack/observer/steps/sync_networks.py index 7ae7dc2..eb8fe86 100644 --- a/planetstack/observer/steps/sync_networks.py +++ b/planetstack/observer/steps/sync_networks.py @@ -4,6 +4,7 @@ from planetstack.config import Config class SyncNetworks(OpenStackSyncStep): provides=[Network] + requested_interval = 0 def save_network(self, network): if not network.network_id: diff --git a/planetstack/observer/steps/sync_site_privileges.py b/planetstack/observer/steps/sync_site_privileges.py index 8f8f8ac..273fd33 100644 --- a/planetstack/observer/steps/sync_site_privileges.py +++ b/planetstack/observer/steps/sync_site_privileges.py @@ -3,6 +3,8 @@ import base64 from planetstack.config import Config class SyncSitePrivileges(OpenStackSyncStep): + requested_interval=0 + provides=[SitePrivilege] def sync_record(self, user): if site_priv.user.kuser_id and site_priv.site.tenant_id: diff --git a/planetstack/observer/steps/sync_sites.py b/planetstack/observer/steps/sync_sites.py index 5d7cc30..59f32e6 100644 --- a/planetstack/observer/steps/sync_sites.py +++ b/planetstack/observer/steps/sync_sites.py @@ -4,6 +4,7 @@ from planetstack.config import Config class SyncSites(OpenStackSyncStep): provides=[Site] + requested_interval=0 def sync_record(self, site): save_site = False if not site.tenant_id: diff --git a/planetstack/observer/steps/sync_slice_memberships.py b/planetstack/observer/steps/sync_slice_memberships.py index a0c83eb..c97bd49 100644 --- a/planetstack/observer/steps/sync_slice_memberships.py +++ b/planetstack/observer/steps/sync_slice_memberships.py @@ -3,6 +3,7 @@ import base64 from planetstack.config import Config class SyncSliceMemberships(OpenStackSyncStep): + requested_interval=0 provides=[SliceMembership] def sync_record(self, user): if slice_memb.user.kuser_id and slice_memb.slice.tenant_id: diff --git a/planetstack/observer/steps/sync_slices.py b/planetstack/observer/steps/sync_slices.py index 736fde6..fb787db 100644 --- a/planetstack/observer/steps/sync_slices.py +++ b/planetstack/observer/steps/sync_slices.py @@ -4,6 +4,7 @@ from planetstack.config import Config class SyncSlices(OpenStackSyncStep): provides=[Slice] + requested_interval=0 def sync_record(self, slice): if not slice.tenant_id: nova_fields = {'tenant_name': slice.name, diff --git a/planetstack/observer/steps/sync_sliver_ips.py b/planetstack/observer/steps/sync_sliver_ips.py index 4421ca5..93f8cb3 100644 --- a/planetstack/observer/steps/sync_sliver_ips.py +++ b/planetstack/observer/steps/sync_sliver_ips.py @@ -4,6 +4,7 @@ from planetstack.config import Config class SyncSliverIps(OpenStackSyncStep): provides=[Sliver] + requested_interval=0 def fetch_pending(self): slivers = Sliver.objects.filter(ip=None) return slivers diff --git a/planetstack/observer/steps/sync_slivers.py b/planetstack/observer/steps/sync_slivers.py index a8ef822..46f78fd 100644 --- a/planetstack/observer/steps/sync_slivers.py +++ b/planetstack/observer/steps/sync_slivers.py @@ -4,6 +4,7 @@ from planetstack.config import Config class SyncSlivers(OpenStackSyncStep): provides=[Sliver] + requested_interval=0 def sync_record(self, slice): if not sliver.instance_id: nics = self.get_requested_networks(sliver.slice) diff --git a/planetstack/observer/steps/sync_users.py b/planetstack/observer/steps/sync_users.py index af1bc30..1e93034 100644 --- a/planetstack/observer/steps/sync_users.py +++ b/planetstack/observer/steps/sync_users.py @@ -4,6 +4,7 @@ from planetstack.config import Config class SyncUsers(OpenStackSyncStep): provides=[User] + requested_interval=0 def sync_record(self, user): name = user.email[:user.email.find('@')] user_fields = {'name': name, -- 2.43.0