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
--- a/planetstack/observer/steps/sync_external_routes.py
+++ b/planetstack/observer/steps/sync_external_routes.py
@@ -4,6 +4,8 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
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 @@
class SyncUsers(OpenStackSyncStep):
provides=[User]
+ requested_interval=0
def sync_record(self, user):
name = user.email[:user.email.find('@')]
user_fields = {'name': name,