|
@@ -256,7 +256,6 @@ class WARC: |
|
|
|
|
|
|
|
|
def _write_meta_warc(self, callback): |
|
|
def _write_meta_warc(self, callback): |
|
|
filename = f'{self._prefix}-meta.warc.gz' |
|
|
filename = f'{self._prefix}-meta.warc.gz' |
|
|
#TODO: Handle OSError on fcntl.flock and retry |
|
|
|
|
|
self._file = open(filename, 'ab') |
|
|
self._file = open(filename, 'ab') |
|
|
try: |
|
|
try: |
|
|
fcntl.flock(self._file.fileno(), fcntl.LOCK_EX) |
|
|
fcntl.flock(self._file.fileno(), fcntl.LOCK_EX) |
|
|