PREFIX submissionOntology: <http://jumpgate.caltech.edu/wiki/UcscSubmissionOntology#>
PREFIX ucscDaf: <http://jumpgate.caltech.edu/wiki/UcscDaf#>
-select ?submitView ?filename ?md5sum ?view ?cell ?antibody ?sex ?control ?controlId ?labExpId ?labVersion ?treatment ?protocol
+select ?submitView ?files ?md5sum ?view ?cell ?antibody ?sex ?control ?controlId ?labExpId ?labVersion ?treatment ?protocol
WHERE {
- ?file ucscDaf:filename ?filename ;
+ ?file ucscDaf:filename ?files ;
ucscDaf:md5sum ?md5sum .
?submitView ucscDaf:has_file ?file ;
ucscDaf:view ?dafView ;
- ucscDaf:submission %(submission)s .
+ ucscDaf:submission <%(submission)s> .
?dafView ucscDaf:name ?view .
- %(submission)s submissionOntology:library ?library .
+ <%(submission)s> submissionOntology:library ?library .
OPTIONAL { ?submitView ucscDaf:antibody ?antibody }
OPTIONAL { ?submitView ucscDaf:cell ?cell }
else:
output = sys.stdout
- formatted_query = query_template % {'submission': str(submissionNode)}
+ formatted_query = query_template % {'submission': str(submissionNode.uri)}
query = RDF.SPARQLQuery(formatted_query)
results = query.execute(view_map.model)
- variables = ['filename']
+ variables = ['files']
# filename goes first
variables.extend(view_map.get_daf_variables())
variables += ['controlId', 'labExpId', 'md5sum']
current = all_views.setdefault(viewname, {})
for variable_name in variables:
value = str(fromTypedNode(row[variable_name]))
- if variable_name in ('filename', 'md5sum'):
+ if variable_name in ('files', 'md5sum'):
current.setdefault(variable_name,[]).append(value)
else:
current[variable_name] = value
for view in all_views.keys():
line = []
for variable_name in variables:
- if variable_name in ('filename', 'md5sum'):
+ if variable_name in ('files', 'md5sum'):
line.append(','.join(all_views[view][variable_name]))
else:
line.append(all_views[view][variable_name])
output.write("\t".join(line))
output.write(os.linesep)
- all_files.extend(all_views[view]['filename'])
+ all_files.extend(all_views[view]['files'])
logging.info(
"Examined {0}, found files: {1}".format(
class Lane(models.Model):
flowcell = models.ForeignKey(FlowCell)
- lane_number = models.IntegerField(validators=[is_valid_lane])
+ lane_number = models.IntegerField()
library = models.ForeignKey(Library)
pM = models.DecimalField(max_digits=5, decimal_places=2,blank=False, null=False,default=default_pM)
cluster_estimate = models.IntegerField(blank=True, null=True)
[str(self.id)])
def __unicode__(self):
- return self.flowcell.flowcell_id + ':' + unicode(self.lane_number)
-
+ return self.flowcell.flowcell_id + ':' + unicode(self.lane_number)
+
### -----------------------
class DataRun(models.Model):
flowcell = models.ForeignKey(FlowCell,verbose_name="Flowcell Id")
submission_name = self.make_submission_name(submission_dir)
submissionNode = self.get_submission_node(submission_dir)
submission_uri = str(submissionNode.uri)
- view_name = fromTypedNode(self.model.get_target(view, dafTermOntology['name']))
+ view_name = str(fromTypedNode(self.model.get_target(view, dafTermOntology['name'])))
submissionView = RDF.Node(RDF.Uri(submission_uri + '/' + view_name))
self.model.add_statement(
# Add everything I can find
for term in terms:
- value = self._get_library_attribute(libNode, term)
+ value = str(self._get_library_attribute(libNode, term))
if value is not None:
self.model.add_statement(RDF.Statement(submissionView, term, value))