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 |
> |
# lfnbase = os.path.join(lfnbase, "user", getUserName(LocalUser=LocalUser), PrimaryDataset, ProcessedDataset ) |
22 |
> |
lfnbase = os.path.join(forced_path, getUserName(LocalUser=LocalUser), PrimaryDataset, ProcessedDataset) |
23 |
|
|
24 |
|
return lfnbase |
25 |
|
|
90 |
|
nameuser = line |
91 |
|
userfile.close() |
92 |
|
nameuser = string.strip(nameuser) |
93 |
< |
return nameuser |
93 |
> |
return nameuser |
94 |
|
|
95 |
|
def getUserName(LocalUser=False): |
96 |
|
""" |