Skip to content

Commit

Permalink
extra comma stopped scheduler server from being detected
Browse files Browse the repository at this point in the history
  • Loading branch information
rays committed Jul 21, 2010
1 parent b76cc77 commit 3d3dc40
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 5 deletions.
3 changes: 2 additions & 1 deletion awspider/servers2/base.py
Expand Up @@ -69,7 +69,7 @@ def __init__(self,
self.aws_access_key_id,
self.aws_secret_access_key,
rq=self.rq)
self.scheduler_server_group=scheduler_server_group,
self.scheduler_server_group=scheduler_server_group
self.pg = PageGetter(
self.s3,
self.aws_s3_http_cache_bucket,
Expand Down Expand Up @@ -221,6 +221,7 @@ def setSchedulerServer(self):
if scheduler_hostnames:
self.scheduler_server = scheduler_hostnames[0]
if not self.scheduler_server:
LOGGER.error('No scheduler server found, using 0.0.0.0')
self.scheduler_server = "0.0.0.0"
LOGGER.debug('Scheduler Server found at %s' % self.scheduler_server)
except Exception, e:
Expand Down
7 changes: 4 additions & 3 deletions awspider/servers2/interface.py
Expand Up @@ -23,6 +23,7 @@ def __init__(self,
aws_secret_access_key,
aws_s3_http_cache_bucket=None,
aws_s3_storage_bucket=None,
remote_scheduler=True,
scheduler_server_group='flavors_spider_production',
schedulerserver_port=5004,
max_simultaneous_requests=50,
Expand All @@ -36,6 +37,7 @@ def __init__(self,
self.aws_secret_access_key=aws_secret_access_key
self.scheduler_server_group=scheduler_server_group
self.schedulerserver_port=schedulerserver_port
self.remote_scheduler=remote_scheduler
resource = Resource()
interface_resource = InterfaceResource(self)
resource.putChild("interface", interface_resource)
Expand Down Expand Up @@ -135,7 +137,7 @@ def createReservation(self, function_name, **kwargs):
return d

def _createReservationCallback(self, data, function_name, uuid):
if self.scheduler_server:
if self.remote_scheduler:
parameters = {
'uuid': uuid,
'type': function_name
Expand All @@ -148,8 +150,7 @@ def _createReservationCallback(self, data, function_name, uuid):
d.addErrback(self._createReservationErrback, function_name, uuid)
return d
else:
LOGGER.error('No scheduler server defined...')
raise
self._createReservationCallback2(data, function_name, uuid, data)

def _createReservationCallback2(self, data, function_name, uuid, reservation_data):
LOGGER.debug("Function %s returned successfully." % (function_name))
Expand Down
2 changes: 1 addition & 1 deletion setup.py
Expand Up @@ -4,7 +4,7 @@

name = "AWSpider",

version = "0.3.2.10",
version = "0.3.2.11",

packages = find_packages(),

Expand Down

0 comments on commit 3d3dc40

Please sign in to comment.