git://git.onelab.eu
/
plstackapi.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
13c7f11
)
Schedules for various steps
author
Sapan Bhatia
<gwsapan@gmail.com>
Mon, 2 Sep 2013 18:30:37 +0000
(14:30 -0400)
committer
Sapan Bhatia
<gwsapan@gmail.com>
Mon, 2 Sep 2013 18:30:37 +0000
(14:30 -0400)
planetstack/observer/steps/sync_external_routes.py
patch
|
blob
|
history
planetstack/observer/steps/sync_network_slivers.py
patch
|
blob
|
history
planetstack/observer/steps/sync_networks.py
patch
|
blob
|
history
planetstack/observer/steps/sync_site_privileges.py
patch
|
blob
|
history
planetstack/observer/steps/sync_sites.py
patch
|
blob
|
history
planetstack/observer/steps/sync_slice_memberships.py
patch
|
blob
|
history
planetstack/observer/steps/sync_slices.py
patch
|
blob
|
history
planetstack/observer/steps/sync_sliver_ips.py
patch
|
blob
|
history
planetstack/observer/steps/sync_slivers.py
patch
|
blob
|
history
planetstack/observer/steps/sync_users.py
patch
|
blob
|
history
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?
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']
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):
from planetstack.config import Config
class SyncNetworkSlivers(OpenStackSyncStep):
- slow=True
+ requested_interval = 3600
provides=[NetworkSliver]
def call(self):
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]
class SyncNetworks(OpenStackSyncStep):
provides=[Network]
+ requested_interval = 0
def save_network(self, network):
if not network.network_id:
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):
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:
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]
class SyncSites(OpenStackSyncStep):
provides=[Site]
+ requested_interval=0
def sync_record(self, site):
save_site = False
if not site.tenant_id:
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):
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:
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]
class SyncSlices(OpenStackSyncStep):
provides=[Slice]
+ requested_interval=0
def sync_record(self, slice):
if not slice.tenant_id:
nova_fields = {'tenant_name': slice.name,
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]
class SyncSliverIps(OpenStackSyncStep):
provides=[Sliver]
+ requested_interval=0
def fetch_pending(self):
slivers = Sliver.objects.filter(ip=None)
return slivers
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]
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)
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]
class SyncUsers(OpenStackSyncStep):
provides=[User]
+ requested_interval=0
def sync_record(self, user):
name = user.email[:user.email.find('@')]
user_fields = {'name': name,
def sync_record(self, user):
name = user.email[:user.email.find('@')]
user_fields = {'name': name,