equal
deleted
inserted
replaced
1154 stack[0] = self.source_execute |
1154 stack[0] = self.source_execute |
1155 |
1155 |
1156 def as_sql(self, backend, args): |
1156 def as_sql(self, backend, args): |
1157 raise NotImplementedError('source only callback') |
1157 raise NotImplementedError('source only callback') |
1158 |
1158 |
1159 def source_execute(self, source, value): |
1159 def source_execute(self, source, session, value): |
1160 fpath = source.binary_to_str(value) |
1160 fpath = source.binary_to_str(value) |
1161 try: |
1161 try: |
1162 return Binary(fpath) |
1162 return Binary(fpath) |
1163 except OSError, ex: |
1163 except OSError, ex: |
1164 self.critical("can't open %s: %s", fpath, ex) |
1164 self.critical("can't open %s: %s", fpath, ex) |