10 |
|
from ProdCommon.SiteDB.SiteDB import SiteDBJSON |
11 |
|
|
12 |
|
|
13 |
< |
def LFNBase(ProcessedDataset,merged=True,LocalUser=False): |
13 |
> |
def LFNBase(PrimaryDataset='',ProcessedDataset='',merged=True,LocalUser=False,publish=False): |
14 |
|
""" |
15 |
|
""" |
16 |
|
lfnbase = "/store" |
17 |
|
if not merged: |
18 |
|
lfnbase = os.path.join(lfnbase,"tmp") |
19 |
< |
lfnbase = os.path.join(lfnbase, "user", getUserName(LocalUser=LocalUser), ProcessedDataset ) |
19 |
> |
if (PrimaryDataset == 'null'): |
20 |
> |
PrimaryDataset = ProcessedDataset |
21 |
> |
lfnbase = os.path.join(lfnbase, "user", getUserName(LocalUser=LocalUser), PrimaryDataset, ProcessedDataset ) |
22 |
|
|
23 |
|
return lfnbase |
24 |
|
|
23 |
– |
def PFNportion(ProcessedDataset,LocalUser=False): |
24 |
– |
pfnpath = os.path.join(getUserName(LocalUser=LocalUser), ProcessedDataset ) |
25 |
– |
return pfnpath |
26 |
– |
|
25 |
|
def getUnixUserName(): |
26 |
|
""" |
27 |
|
extract username from whoami |
73 |
|
extract user name from either SiteDB or Unix |
74 |
|
""" |
75 |
|
if LocalUser: |
76 |
< |
common.logger.message("==> Using as username the Unix user name") |
76 |
> |
common.logger.debug(10,"Using as username the Unix user name") |
77 |
|
UserName=getUnixUserName() |
78 |
|
return UserName |
79 |
|
|