Schedules for various steps

diff --git a/planetstack/observer/steps/sync_external_routes.py b/planetstack/observer/steps/sync_external_routes.py
index ba4f939..fda66bd 100644 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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 (file)
--- 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,