Sanin example

example.py

def test_enqueue_geohash_fetch(redis_conn):
  enqueue_geohash_fetch()
  
  # NOTE: provjeris ovjde da li je job enqueuan na zadanom queue i ima odgovarajuce parametrom
  redis_conn.get("___")
  

@task
def enqueue_geohash_fetch():
  """Enqueues retrieval job for each tenant every N hours."""
  qs = Client.objects.exclude(tenant_name__startwith="demo_").all()
  for client in qs:
    import_geohash.delay(client)
  
  

@task
def import_geohash(tenant_name, ...):
   """Get geohash for a tenant."""
   ...