Skip to content

Commit

Permalink
Set current GortObserve instance in Gort
Browse files Browse the repository at this point in the history
  • Loading branch information
albireox committed Jul 29, 2024
1 parent fdead21 commit fc5891d
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 1 deletion.
17 changes: 17 additions & 0 deletions src/gort/gort.py
Original file line number Diff line number Diff line change
Expand Up @@ -637,9 +637,23 @@ def __init__(

super().__init__(*args, **kwargs)

self._observer: GortObserver | None = None

if verbosity:
self.set_verbosity(verbosity)

@property
def observer(self) -> GortObserver | None:
"""Returns the current :ref:`observer <.GortObserver>` instance."""

return self._observer

@observer.setter
def observer(self, observer: GortObserver | None):
"""Sets the current :ref:`observer <.GortObserver>` instance."""

self._observer = observer

async def emergency_close(self):
"""Parks and closes the telescopes."""

Expand Down Expand Up @@ -827,6 +841,7 @@ async def observe_tile(

# Create observer.
observer = GortObserver(self, tile, on_interrupt=interrupt_cb)
self.observer = observer

# Run the cleanup routine to be extra sure.
if run_cleanup:
Expand Down Expand Up @@ -904,6 +919,8 @@ async def observe_tile(
# Finish observation.
await observer.finish_observation()

self.observer = None

return exposures

async def run_script(self, script: str):
Expand Down
2 changes: 1 addition & 1 deletion src/gort/overwatcher/observer.py
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,7 @@ async def observe_loop_task(self):
self.next_exposure_completes = time() + 90 + 900 + 60
exp = await self.gort.observe_tile(
run_cleanup=False,
cleanup_on_interrrupt=False,
cleanup_on_interrupt=False,
show_progress=False,
)

Expand Down

0 comments on commit fc5891d

Please sign in to comment.