20 |
|
def run(self): |
21 |
|
""" |
22 |
|
""" |
23 |
+ |
|
24 |
|
common.logger.debug("CredentialRenew::run() called") |
24 |
– |
## TEMPORARY FIXME |
25 |
– |
if self.credentialType == 'Proxy': |
26 |
– |
subServer = SubmitterServer(self.cfg_params, None, "all") |
27 |
– |
subServer.moveProxy() |
28 |
– |
else: |
29 |
– |
self.renewer() |
30 |
– |
common.logger.info("Credential successfully delegated to the server.\n") |
31 |
– |
return |
25 |
|
|
26 |
< |
def renewer(self): |
27 |
< |
""" |
28 |
< |
""" |
29 |
< |
myproxyserver = self.cfg_params.get('GRID.proxy_server', 'myproxy.cern.ch') |
26 |
> |
# FIXME With MyProxy delegation this part is completely overlapped with the method manageDelegation |
27 |
> |
# in SubmitServer. We should to maintain just one version of the method in a common part |
28 |
> |
|
29 |
> |
try: |
30 |
> |
myproxyserver = Downloader("http://cmsdoc.cern.ch/cms/LCG/crab/config/").config("myproxy_server.conf") |
31 |
> |
if myproxyserver is None: |
32 |
> |
raise CrabException("myproxy_server.conf retrieved but empty") |
33 |
> |
except Exception, e: |
34 |
> |
common.logger.info("Problem setting myproxy server endpoint: using myproxy.cern.ch") |
35 |
> |
common.logger.debug(e) |
36 |
> |
myproxyserver = 'myproxy.cern.ch' |
37 |
> |
|
38 |
|
configAPI = {'credential' : self.credentialType, \ |
39 |
|
'myProxySvr' : myproxyserver,\ |
40 |
|
'serverDN' : self.server_dn,\ |
44 |
|
'logger' : common.logger() \ |
45 |
|
} |
46 |
|
try: |
47 |
< |
CredAPI = CredentialAPI( configAPI ) |
48 |
< |
except Exception, err : |
47 |
> |
CredAPI = CredentialAPI( configAPI ) |
48 |
> |
except Exception, err : |
49 |
|
common.logger.debug( "Configuring Credential API: " +str(traceback.format_exc())) |
50 |
|
raise CrabException("ERROR: Unable to configure Credential Client API %s\n"%str(err)) |
51 |
< |
if not CredAPI.checkCredential(Time=100) : |
52 |
< |
common.logger.info("Please renew your %s :\n"%self.credentialType) |
53 |
< |
try: |
54 |
< |
CredAPI.ManualRenewCredential() |
55 |
< |
except Exception, ex: |
56 |
< |
raise CrabException(str(ex)) |
57 |
< |
try: |
58 |
< |
dict = CredAPI.registerCredential() |
59 |
< |
except Exception, err: |
60 |
< |
common.logger.debug( "Registering Credentials : " +str(traceback.format_exc())) |
61 |
< |
raise CrabException("ERROR: Unable to register %s delegating server: %s\n"%(self.credentialType,self.server_name )) |
51 |
> |
|
52 |
> |
if self.credentialType == 'Proxy': |
53 |
> |
# Proxy delegation through MyProxy, 4 days lifetime minimum |
54 |
> |
if not CredAPI.checkMyProxy(Time=4, checkRetrieverRenewer=True) : |
55 |
> |
common.logger.info("Please renew MyProxy delegated proxy:\n") |
56 |
> |
try: |
57 |
> |
CredAPI.credObj.serverDN = self.server_dn |
58 |
> |
CredAPI.ManualRenewMyProxy() |
59 |
> |
except Exception, ex: |
60 |
> |
common.logger.debug("Delegating Credentials to MyProxy : " +str(traceback.format_exc())) |
61 |
> |
raise CrabException(str(ex)) |
62 |
> |
else: |
63 |
> |
self.renewer() |
64 |
> |
if not CredAPI.checkCredential(Time=100) : |
65 |
> |
common.logger.info("Please renew your %s :\n"%self.credentialType) |
66 |
> |
try: |
67 |
> |
CredAPI.ManualRenewCredential() |
68 |
> |
except Exception, ex: |
69 |
> |
raise CrabException(str(ex)) |
70 |
> |
try: |
71 |
> |
dict = CredAPI.registerCredential() |
72 |
> |
except Exception, err: |
73 |
> |
common.logger.debug( "Registering Credentials : " +str(traceback.format_exc())) |
74 |
> |
raise CrabException("ERROR: Unable to register %s delegating server: %s\n"%\ |
75 |
> |
(self.credentialType,self.server_name )) |
76 |
> |
|
77 |
> |
common.logger.info("Credential successfully delegated to the server.\n") |
78 |
> |
return |