7 |
|
from crab_util import runCommand, UnixUserName |
8 |
|
import common |
9 |
|
import os, string, time |
10 |
< |
from ProdCommon.SiteDB.SiteDB import SiteDBJSON |
10 |
> |
from WMCore.Services.SiteDB.SiteDB import SiteDBJSON |
11 |
|
|
12 |
|
|
13 |
< |
def LFNBase(PrimaryDataset='',ProcessedDataset='',merged=True,LocalUser=False,publish=False): |
13 |
> |
def LFNBase(forced_path, PrimaryDataset='',ProcessedDataset='',merged=True,LocalUser=False,publish=False): |
14 |
|
""" |
15 |
|
""" |
16 |
< |
lfnbase = "/store" |
17 |
< |
if not merged: |
18 |
< |
lfnbase = os.path.join(lfnbase,"tmp") |
16 |
> |
#lfnbase = "/store" |
17 |
> |
#if not merged: |
18 |
> |
#lfnbase = os.path.join(lfnbase,"tmp") |
19 |
|
if (PrimaryDataset == 'null'): |
20 |
|
PrimaryDataset = ProcessedDataset |
21 |
< |
lfnbase = os.path.join(lfnbase, "user", getUserName(LocalUser=LocalUser), PrimaryDataset, ProcessedDataset ) |
21 |
> |
if PrimaryDataset != '': |
22 |
> |
if ( PrimaryDataset[0] == '/' ): PrimaryDataset=PrimaryDataset[1:] |
23 |
> |
# lfnbase = os.path.join(lfnbase, "user", getUserName(LocalUser=LocalUser), PrimaryDataset, ProcessedDataset ) |
24 |
> |
lfnbase = os.path.join(forced_path, getUserName(LocalUser=LocalUser), PrimaryDataset, ProcessedDataset) |
25 |
|
|
26 |
|
return lfnbase |
27 |
|
|
92 |
|
nameuser = line |
93 |
|
userfile.close() |
94 |
|
nameuser = string.strip(nameuser) |
95 |
< |
return nameuser |
95 |
> |
return nameuser |
96 |
|
|
97 |
|
def getUserName(LocalUser=False): |
98 |
|
""" |