Home
last modified time | relevance | path

Searched refs:jobdir (Results 1 – 25 of 43) sorted by relevance

12

/dports/www/py-scrapy/Scrapy-2.5.1/scrapy/extensions/
H A Dspiderstate.py12 def __init__(self, jobdir=None): argument
13 self.jobdir = jobdir
17 jobdir = job_dir(crawler.settings)
18 if not jobdir:
21 obj = cls(jobdir)
27 if self.jobdir:
32 if self.jobdir and os.path.exists(self.statefn):
40 return os.path.join(self.jobdir, 'spider.state')
/dports/sysutils/uschedule/admin/uschedule-0.7.1/src/
H A Duscheduleconf.c77 const char *jobdir=0; in main() local
91 jobdir=argv[4]; in main()
103 if (jobdir) BAND_AID(jobdir); in main()
132 if (!jobdir || str_equal(jobdir,"-")) { in main()
138 jobdir=d.s; in main()
139 BAND_AID(jobdir); in main()
143 if (!stralloc_copys(&d,jobdir)) oom(); in main()
163 outs("cd '"); outs(jobdir); outs("' || exit 1\n"); in main()
186 make_dir(jobdir); in main()
189 set_dir(jobdir); in main()
[all …]
/dports/biology/py-ete3/ete3-3.1.2/ete3/tools/ete_build_lib/
H A Dmaster_job.py126 self.jobdir = basepath
129 self.status_file = os.path.join(self.jobdir, "__status__")
130 self.time_file = os.path.join(self.jobdir, "__time__")
131 self.cmd_file = os.path.join(self.jobdir, "__cmd__")
132 self.stdout_file = os.path.join(self.jobdir, "__stdout__")
133 self.stderr_file = os.path.join(self.jobdir, "__stderr__")
134 self.pid_file = os.path.join(self.jobdir, "__pid__")
168 if not os.path.exists(self.jobdir):
169 os.makedirs(self.jobdir)
224 if os.path.exists(self.jobdir):
[all …]
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/test/integration/
H A Dtest_try_client.py50 tmpfile = os.path.join(self.jobdir, 'tmp', 'testy')
51 newfile = os.path.join(self.jobdir, 'new', 'testy')
88 jobdir = FilePath(self.mktemp())
89 jobdir.createDirectory()
90 self.jobdir = jobdir.path
92 jobdir.child(sub).createDirectory()
93 return self.jobdir
236 jobdir = self.setupJobdir()
237 yield self.startMaster(trysched.Try_Jobdir('try', ['a'], jobdir))
256 jobdir = self.setupJobdir()
[all …]
/dports/www/py-scrapy/Scrapy-2.5.1/tests/
H A Dtest_spiderstate.py15 jobdir = self.mktemp()
16 os.mkdir(jobdir)
21 ss = SpiderState(jobdir)
28 ss2 = SpiderState(jobdir)
33 shutil.rmtree(jobdir)
H A Dtest_scheduler.py46 def __init__(self, priority_queue_cls, jobdir): argument
53 JOBDIR=jobdir,
62 jobdir = None variable in SchedulerHandler
65 self.mock_crawler = MockCrawler(self.priority_queue_cls, self.jobdir)
128 self.jobdir = tempfile.mkdtemp()
134 shutil.rmtree(self.jobdir)
135 self.jobdir = None
205 prev_scheduler_handler.jobdir = tmp_dir
214 next_scheduler_handler.jobdir = tmp_dir
/dports/biology/py-ete3/ete3-3.1.2/ete3/tools/ete_build_lib/task/
H A Dprottest.py104 bionj_job.add_input_file(self.alg_phylip_file, bionj_job.jobdir)
110 "-s": pjoin(bionj_job.jobdir, self.alg_phylip_file),
113 "-t": pjoin(bionj_job.jobdir,
130 tree_file = pjoin(phyml_job.jobdir,
132 stats_file = pjoin(phyml_job.jobdir,
145 lk = open(pjoin(raxml_job.jobdir, "RAxML_log.%s"
H A Dphyml.py156 job.add_input_file(self.alg_phylip_file, job.jobdir)
158 job.add_input_file(self.constrain_tree, job.jobdir)
165 tree_file = os.path.join(j.jobdir,
167 stats_file = os.path.join(j.jobdir,
H A Draxml.py167 self.out_tree_file = os.path.join(tree_job.jobdir,
209 alrt_job.add_input_file(self.alg_phylip_file, alrt_job.jobdir)
247 bootd_args["-z"] = pjoin(boot_job.jobdir, "RAxML_bootstrap." + boot_job.args["-n"])
267 alrt_tree_file = os.path.join(self.alrt_job.jobdir,
280 alrt_tree_file = os.path.join(self.alrt_job.jobdir,
285 alrt_tree_file = os.path.join(self.bootd_job.jobdir,
H A Dprottest2.py94 fake_alg_file = os.path.join(job.jobdir, self.alg_basename)
134 tree_file = os.path.join(job.jobdir,
136 stats_file = os.path.join(j.jobdir,
147 lk = open(os.path.join(job.jobdir, "RAxML_log.%s"
H A Diqtree.py65 job.add_input_file(self.alg_phylip_file, job.jobdir)
72 tree_file = os.path.join(j.jobdir,
74 stats_file = os.path.join(j.jobdir,
H A Ddialigntx.py82 alg = SeqGroup(os.path.join(self.jobs[0].jobdir, "alg.fasta"))
H A Dmuscle.py80 alg = SeqGroup(os.path.join(self.jobs[0].jobdir, "muscle_alg.fasta"))
H A Dmeta_aligner.py97 alg = SeqGroup(os.path.join(self.jobs[0].jobdir, "mcoffee.fasta"))
216 alg = SeqGroup(pjoin(trim_job.jobdir, trim_job.alg_fasta_file))
H A Dclustalo.py86 alg_file = os.path.join(self.jobs[0].jobdir, "clustalo_alg.fasta")
/dports/www/py-scrapy/Scrapy-2.5.1/scrapy/core/
H A Dscheduler.py38 def __init__(self, dupefilter, jobdir=None, dqclass=None, mqclass=None, argument
41 self.dqdir = self._dqdir(jobdir)
58 return cls(dupefilter, jobdir=job_dir(settings), logunser=logunser,
153 def _dqdir(self, jobdir): argument
155 if jobdir:
156 dqdir = join(jobdir, 'requests.queue')
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/scripts/
H A Dtryserver.py26 jobdir = os.path.expanduser(config["jobdir"])
37 tmpfile = os.path.join(jobdir, "tmp", fn)
38 newfile = os.path.join(jobdir, "new", fn)
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-extras/src/main/java/org/apache/hadoop/tools/
H A DDistCh.java394 final String jobdir = jobconf.get(JOB_DIR_LABEL); in run() local
395 if (jobdir != null) { in run()
396 final Path jobpath = new Path(jobdir); in run()
431 Path jobdir = new Path(stagingArea + NAME + "_" + randomId); in setup() local
434 FileSystem.mkdirs(jClient.getFs(), jobdir, mapredSysPerms); in setup() local
435 LOG.info(JOB_DIR_LABEL + "=" + jobdir); in setup()
438 log = new Path(jobdir, "_logs"); in setup()
444 FileSystem fs = jobdir.getFileSystem(jobconf); in setup()
445 Path opList = new Path(jobdir, "_" + OP_LIST_LABEL); in setup()
478 checkDuplication(fs, opList, new Path(jobdir, "_sorted"), jobconf); in setup()
/dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/
H A DDistCh.java398 final String jobdir = jobconf.get(JOB_DIR_LABEL); in run() local
399 if (jobdir != null) { in run()
400 final Path jobpath = new Path(jobdir); in run()
434 Path jobdir = new Path(stagingArea + NAME + "_" + randomId); in setup() local
437 FileSystem.mkdirs(jClient.getFs(), jobdir, mapredSysPerms); in setup() local
438 LOG.info(JOB_DIR_LABEL + "=" + jobdir); in setup()
441 log = new Path(jobdir, "_logs"); in setup()
447 FileSystem fs = jobdir.getFileSystem(jobconf); in setup()
448 Path opList = new Path(jobdir, "_" + OP_LIST_LABEL); in setup()
485 checkDuplication(fs, opList, new Path(jobdir, "_sorted"), jobconf); in setup()
/dports/devel/py-buildbot/buildbot-3.4.1/buildbot/schedulers/
H A Dtrysched.py84 def __init__(self, name, builderNames, jobdir, **kwargs): argument
86 self.jobdir = jobdir
109 jobdir = os.path.join(self.master.basedir, self.jobdir)
110 self.watcher.setBasedir(jobdir)
112 if not os.path.exists(os.path.join(jobdir, subdir)):
113 os.mkdir(os.path.join(jobdir, subdir))
/dports/astro/oskar/OSKAR-2.8.0/docs/python/
H A Doskar_run_k8s53 -d|--jobdir)
57 --jobdir=?*)
/dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/utilities/logic/
H A Dasync_wrapper.py238 jobdir = os.path.expanduser(async_dir)
239 job_path = os.path.join(jobdir, jid)
242 _make_temp_dir(jobdir)
246 "msg": "could not create: %s - %s" % (jobdir, to_text(e)),
/dports/sysutils/py-ansible-base/ansible-base-2.10.15/lib/ansible/modules/
H A Dasync_wrapper.py234 jobdir = os.path.expanduser(async_dir)
235 job_path = os.path.join(jobdir, jid)
238 _make_temp_dir(jobdir)
242 "msg": "could not create: %s - %s" % (jobdir, to_text(e)),
/dports/sysutils/py-ansible-core/ansible-core-2.11.6/lib/ansible/modules/
H A Dasync_wrapper.py234 jobdir = os.path.expanduser(async_dir)
235 job_path = os.path.join(jobdir, jid)
238 _make_temp_dir(jobdir)
242 "msg": "could not create: %s - %s" % (jobdir, to_text(e)),
/dports/astro/astrometry/astrometry.net-0.85/doc/
H A Dnova.rst135 'tar cf - --ignore-failed-read -C %(jobdir)s %(axyfile)s) | '
137 'tar xf - --atime-preserve -m --exclude=%(axyfile)s -C %(jobdir)s '
140 axyfile=axyfn, jobdir=jobdir,

12